Method
stream_request
(
self,
setup: Request,
*,
chunk_size: int = 1024,
)
Source from the content-addressed store, hash-verified
| 222 | |
| 223 | @override |
| 224 | async def stream_request( |
| 225 | self, |
| 226 | setup: Request, |
| 227 | *, |
| 228 | chunk_size: int = 1024, |
| 229 | ) -> AsyncGenerator[Response, None]: |
| 230 | async with self.get_session( |
| 231 | version=setup.version, proxy=setup.proxy |
| 232 | ) as session: |
| 233 | async for response in session.stream_request(setup, chunk_size=chunk_size): |
| 234 | yield response |
| 235 | |
| 236 | @override |
| 237 | def get_session( |