Break loop after result retreival

goodboy · Dec 12, 2022 · eb3d0a8 · eb3d0a8
1 parent ac8313c
commit eb3d0a8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tractor/_streaming.py b/tractor/_streaming.py
@@ -277,7 +277,6 @@ async def aclose(self):
     @asynccontextmanager
     async def subscribe(
         self,
-
     ) -> AsyncIterator[BroadcastReceiver]:
         '''
         Allocate and return a ``BroadcastReceiver`` which delegates
@@ -703,6 +702,7 @@ def consume(
                             result = consume(msg)
                             if result:
                                 self._result = result
+                                break
 
                 if not self._result:
                     while True: