def test_new_thread_now(self):
        scheduler = NewThreadScheduler()
        res = scheduler.now() - datetime.utcnow()
        assert res < timedelta(microseconds=1000)
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_concurrency/test_newthreadscheduler.py/TestNewThreadScheduler.test_new_thread_now/original