goodboy
/
tractor
1
0
Fork 1
Code Issues 1 Pull Requests 4 Packages Projects Releases Wiki Activity

Break loop after result retreival

ctx_result_consumption
Tyler Goodlet 2022-04-10 19:18:40 -04:00
parent a71a958f54
commit 33b0e36ad6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tractor/_streaming.py
View File

@ -286,7 +286,6 @@ class MsgStream(trio.abc.Channel):
@asynccontextmanager @asynccontextmanager
async def subscribe( async def subscribe(
self, self,
) -> AsyncIterator[BroadcastReceiver]: ) -> AsyncIterator[BroadcastReceiver]:
''' '''
Allocate and return a ``BroadcastReceiver`` which delegates Allocate and return a ``BroadcastReceiver`` which delegates
@ -705,6 +704,7 @@ class Context:
result = consume(msg) result = consume(msg)
if result: if result:
self._result = result self._result = result
break
if not self._result: if not self._result:
while True: while True: