Fix tests

tests/test_chain.py

@@ -34,7 +34,7 @@ def mapper(value: int) -> int:
         (0, OnNext(10)),
         (0, OnNext(20)),
         (0, OnNext(30)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -58,7 +58,7 @@ async def predicate(value: int) -> bool:
     assert obv.values == [
         (ca(0.2), OnNext(20)),
         (ca(0.3), OnNext(30)),
-        (ca(0.3), OnCompleted),
+        (ca(0.3), OnCompleted()),
     ]
 
 
@@ -84,5 +84,5 @@ async def long_running(value: int) -> AsyncObservable[int]:
     assert obv.values == [
         (ca(0.2), OnNext(20)),
         (ca(0.3), OnNext(30)),
-        (ca(0.3), OnCompleted),
+        (ca(0.3), OnCompleted()),
     ]

tests/test_debounce.py

@@ -44,7 +44,7 @@ async def test_debounce():
     assert obv.values == [
         (ca(0.5), OnNext(1)),
         (ca(1.1), OnNext(2)),
-        (ca(1.2), OnCompleted),
+        (ca(1.2), OnCompleted()),
     ]
 
     await subscription.dispose_async()
@@ -68,7 +68,7 @@ async def test_debounce_filter():
 
     assert obv.values == [
         (ca(0.8), OnNext(2)),
-        (ca(0.9), OnCompleted),
+        (ca(0.9), OnCompleted()),
     ]
 
     await subscription.dispose_async()

tests/test_delay.py

@@ -39,7 +39,7 @@ async def test_delay_done():
     assert obv.values == [
         (ca(1), OnNext(10)),
         (ca(2), OnNext(20)),
-        (ca(3), OnCompleted),
+        (ca(3), OnCompleted()),
     ]
 
 

tests/test_distinct_until_changed.py

@@ -30,7 +30,7 @@ async def test_distinct_until_changed_different():
         (0, OnNext(1)),
         (0, OnNext(2)),
         (0, OnNext(3)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -49,5 +49,5 @@ async def test_distinct_until_changed_changed():
         (0, OnNext(3)),
         (0, OnNext(1)),
         (0, OnNext(2)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]

tests/test_flat_map.py

@@ -31,7 +31,7 @@ def mapper(value: int) -> rx.AsyncObservable[int]:
     await xs.aclose()
     await obv
 
-    assert obv.values == [(0, OnNext(10)), (0, OnNext(20)), (0, OnCompleted)]
+    assert obv.values == [(0, OnNext(10)), (0, OnNext(20)), (0, OnCompleted())]
 
 
 @pytest.mark.asyncio

tests/test_forward_pipe.py

@@ -34,7 +34,7 @@ def mapper(value: int) -> int:
         (0, OnNext(10)),
         (0, OnNext(20)),
         (0, OnNext(30)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -57,7 +57,7 @@ async def predicate(value: int) -> bool:
 
     obv: AsyncTestObserver[int] = AsyncTestObserver()
     await rx.run(ys, obv)
-    assert obv.values == [(0, OnNext(20)), (0, OnNext(30)), (0, OnCompleted)]
+    assert obv.values == [(0, OnNext(20)), (0, OnNext(30)), (0, OnCompleted())]
 
 
 @pytest.mark.asyncio

tests/test_from_iterable.py

@@ -22,7 +22,7 @@ async def test_from_iterable_happy():
         (0, OnNext(1)),
         (0, OnNext(2)),
         (0, OnNext(3)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -62,4 +62,4 @@ async def asend(value: int) -> None:
 #     # with pytest.raises(asyncio.CancelledError):
 #     await obv
 
-#     assert obv.values == [(0, OnNext(0)), (0, OnCompleted)]
+#     assert obv.values == [(0, OnNext(0)), (0, OnCompleted())]

tests/test_merge.py

@@ -35,7 +35,7 @@ async def test_merge_done():
     await xs.aclose()
     await obv
 
-    assert obv.values == [(0, OnNext(10)), (0, OnNext(20)), (0, OnCompleted)]
+    assert obv.values == [(0, OnNext(10)), (0, OnNext(20)), (0, OnCompleted())]
 
 
 @pytest.mark.asyncio
@@ -71,7 +71,7 @@ async def test_merge_streams():
         (3, OnNext(50)),
         (4, OnNext(30)),
         (5, OnNext(60)),
-        (6, OnCompleted),
+        (6, OnCompleted()),
     ]
 
 
@@ -101,5 +101,5 @@ async def test_merge_streams_concat():
         (6, OnNext(1)),
         (6, OnNext(2)),
         (6, OnNext(3)),
-        (6, OnCompleted),
+        (6, OnCompleted()),
     ]

tests/test_pipe.py

@@ -37,7 +37,7 @@ def mapper(value: int) -> int:
         (0, OnNext(10)),
         (0, OnNext(20)),
         (0, OnNext(30)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -59,7 +59,7 @@ async def predicate(value: int) -> bool:
     assert obv.values == [
         (approx(0.2), OnNext(20)),
         (approx(0.3), OnNext(30)),
-        (approx(0.3), OnCompleted),
+        (approx(0.3), OnCompleted()),
     ]
 
 

tests/test_scan.py

@@ -50,7 +50,7 @@ async def test_scan():
         OnNext(3),
         OnNext(6),
         OnNext(10),
-        OnCompleted,
+        OnCompleted(),
     ]
 
 
@@ -72,5 +72,5 @@ async def test_scan_async():
         OnNext(3),
         OnNext(6),
         OnNext(10),
-        OnCompleted,
+        OnCompleted(),
     ]

tests/test_single.py

@@ -27,7 +27,7 @@ async def test_unit_happy():
 
     obv: AsyncTestObserver[int] = AsyncTestObserver()
     await rx.run(xs, obv)
-    assert obv.values == [(0, OnNext(42)), (0, OnCompleted)]
+    assert obv.values == [(0, OnNext(42)), (0, OnCompleted())]
 
 
 @pytest.mark.asyncio
@@ -65,7 +65,7 @@ async def asend(value: int) -> None:
 
     assert obv.values == [
         (0, OnNext(42)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -79,7 +79,7 @@ async def test_unit_happy_resolved_future():
     await rx.run(xs, obv)
     assert obv.values == [
         (0, OnNext(42)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -95,7 +95,7 @@ async def test_unit_happy_future_resolve():
 
     assert obv.values == [
         (0, OnNext(42)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -125,4 +125,4 @@ async def test_unit_future_cancel():
         with pytest.raises(asyncio.CancelledError):
             await obv
 
-    assert obv.values == [(approx(1), OnCompleted)]
+    assert obv.values == [(approx(1), OnCompleted())]

tests/test_single_stream.py

@@ -82,7 +82,7 @@ async def test_stream_send_after_close():
         (1, OnNext(10)),
         (2, OnNext(20)),
         (3, OnNext(30)),
-        (5, OnCompleted),
+        (5, OnCompleted()),
     ]
 
 
@@ -222,4 +222,4 @@ async def aclose():
     async with await xs.subscribe_async(sink):
         await xs.asend_later(1, 20)
 
-    assert sink.values == [(10, OnCompleted)]
+    assert sink.values == [(10, OnCompleted())]

tests/test_slice.py

@@ -32,7 +32,7 @@ async def test_slice_special():
         (0, OnNext(2)),
         (0, OnNext(3)),
         (0, OnNext(4)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]
 
 
@@ -50,5 +50,5 @@ async def test_slice_step():
         (0, OnNext(1)),
         (0, OnNext(3)),
         (0, OnNext(5)),
-        (0, OnCompleted),
+        (0, OnCompleted()),
     ]

tests/test_stream.py

@@ -84,7 +84,7 @@ async def test_stream_send_after_close() -> None:
         (1, OnNext(10)),
         (2, OnNext(20)),
         (3, OnNext(30)),
-        (5, OnCompleted),
+        (5, OnCompleted()),
     ]
 
 

tests/test_take.py

@@ -30,7 +30,7 @@ async def test_take_zero() -> None:
     with pytest.raises(CancelledError):
         await rx.run(ys, obv)
 
-    assert obv.values == [(0, OnCompleted)]
+    assert obv.values == [(0, OnCompleted())]
 
 
 @pytest.mark.asyncio
@@ -43,7 +43,7 @@ async def test_take_empty() -> None:
     with pytest.raises(CancelledError):
         await rx.run(ys, obv)
 
-    assert obv.values == [(0, OnCompleted)]
+    assert obv.values == [(0, OnCompleted())]
 
 
 @pytest.mark.asyncio
@@ -64,4 +64,4 @@ async def test_take_normal() -> None:
     result = await rx.run(ys, obv)
 
     assert result == 2
-    assert obv.values == [(0, OnNext(1)), (0, OnNext(2)), (0, OnCompleted)]
+    assert obv.values == [(0, OnNext(1)), (0, OnNext(2)), (0, OnCompleted())]

tests/test_with_latest_from.py

@@ -52,7 +52,7 @@ async def test_withlatestfrom_never_never():
 #     with pytest.raises(CancelledError):
 #         await rx.run(zs, obv)
 
-#     assert obv.values == [(0, OnCompleted)]
+#     assert obv.values == [(0, OnCompleted())]
 
 
 # @pytest.mark.asyncio
@@ -70,4 +70,4 @@ async def test_withlatestfrom_never_never():
 #         await xs.aclose()
 #         await obv
 
-#     assert obv.values == [(0, OnNext(5)), (0, OnCompleted)]
+#     assert obv.values == [(0, OnNext(5)), (0, OnCompleted())]