MCPcopy
hub / github.com/encode/httpx / async_streaming_body

Function async_streaming_body

tests/models/test_responses.py:22–24  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

20
21
22async def async_streaming_body() -> typing.AsyncIterator[bytes]:
23 yield b"Hello, "
24 yield b"world!"
25
26
27def autodetect(content):

Callers 11

test_iter_raw_on_asyncFunction · 0.85
test_close_on_asyncFunction · 0.85
test_aiter_rawFunction · 0.85
test_aiter_raw_with_chunksizeFunction · 0.85
test_aiter_raw_increments_updates_counterFunction · 0.85
test_aiter_bytes_with_chunk_sizeFunction · 0.85
test_async_streaming_responseFunction · 0.85
test_cannot_aread_after_stream_consumedFunction · 0.85
test_cannot_aread_after_response_closedFunction · 0.85
test_elapsed_not_available_until_closedFunction · 0.85
test_response_async_streaming_picklableFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected