Handle not all values pulled case

goodboy · Apr 12, 2022 · edfb25e · edfb25e
1 parent 333fad8
commit edfb25e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/test_infected_asyncio.py b/tests/test_infected_asyncio.py
@@ -280,7 +280,7 @@ async def consume(
                 # we get double the pulled values in the
                 # ``.subscribe()`` fan out case.
                 doubled = list(itertools.chain(*zip(expect, expect)))
-                assert pulled == doubled
+                assert pulled == doubled[:len(pulled)]
 
             else:
                 assert pulled == expect