From fa354ffe2b832ed6a988a381080c027e71f143e1 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Tue, 12 Apr 2022 15:24:16 -0400
Subject: [PATCH] Handle not all values pulled case

---
 tests/test_infected_asyncio.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/test_infected_asyncio.py b/tests/test_infected_asyncio.py
index cb0a400..88fce6d 100644
--- a/tests/test_infected_asyncio.py
+++ b/tests/test_infected_asyncio.py
@@ -280,7 +280,9 @@ async def stream_from_aio(
                 # we get double the pulled values in the
                 # ``.subscribe()`` fan out case.
                 doubled = list(itertools.chain(*zip(expect, expect)))
-                assert pulled == doubled
+                if pulled != doubled[:len(pulled)]:
+                    print(f'uhhh pulled is {pulled}')
+                    assert pulled == doubled[:len(pulled)]
 
             else:
                 assert pulled == expect