1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
import unittest
from reactivex import never
from reactivex.testing import ReactiveTest, TestScheduler
on_next = ReactiveTest.on_next
on_completed = ReactiveTest.on_completed
on_error = ReactiveTest.on_error
subscribe = ReactiveTest.subscribe
subscribed = ReactiveTest.subscribed
disposed = ReactiveTest.disposed
created = ReactiveTest.created
class TestNever(unittest.TestCase):
def test_never_basic(self):
scheduler = TestScheduler()
xs = never()
results = scheduler.create_observer()
xs.subscribe(results)
scheduler.start()
assert results.messages == []
|
