Fix reduce tests

dbrattli · Jan 18, 2024 · dd43379 · dd43379
1 parent f0422c9
commit dd43379
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/test_reduce.py b/tests/test_reduce.py
@@ -40,7 +40,7 @@ async def test_reduce():
     values = list(map(lambda t: t[1], observer.values))
     assert values == [
         OnNext(10),
-        OnCompleted,
+        OnCompleted(),
     ]
 
 
@@ -55,5 +55,5 @@ async def test_reduce_async():
     values = list(map(lambda t: t[1], observer.values))
     assert values == [
         OnNext(10),
-        OnCompleted,
+        OnCompleted(),
     ]