We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7f2ad7 commit f0b14d3Copy full SHA for f0b14d3
src/py/extra/client.py
@@ -436,14 +436,16 @@ async def OnRequest(
436
status = atom
437
elif isinstance(atom, HTTPResponse):
438
res = atom
439
+ yield atom.body
440
break
441
else:
442
yield atom
443
iteration += 1
444
if (
445
+ status is HTTPProcessingStatus.Processing,
446
streaming is True
447
or res
- and res.headers.contentType in {"text/event-stream"}
448
+ and res.headers.contentType in {"text/event-stream"},
449
):
450
# TODO: We should swap out the body for a streaming body
451
cxn.isStreaming = True
0 commit comments