We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 78e676c commit cf293abCopy full SHA for cf293ab
storey/sources.py
@@ -85,7 +85,7 @@ def await_result(self):
85
self._on_error()
86
raise copy.copy(first_result)
87
88
- # Check if this is a streaming response
+ # If this is a stream response, return a generator
89
if isinstance(first_result, (StreamChunk, StreamCompletion)):
90
return self._stream_generator(first_result)
91
@@ -490,7 +490,7 @@ async def await_result(self):
490
await self._on_error()
491
492
493
494
495
496
0 commit comments