langgraph_agent_toolkit.service.responses module

Close response iterators when transport errors stop streaming.

class langgraph_agent_toolkit.service.responses.ClosingStreamingResponse(content, status_code=200, headers=None, media_type=None, background=None)[source][source]

Bases: StreamingResponse

Finish generator cleanup before the request releases its resources.

Parameters:

  • content (ContentStream)

  • status_code (int)

  • headers (Mapping[str, str] | None)

  • media_type (str | None)

  • background (BackgroundTask | None)

async stream_response(send)[source][source]
Parameters:

send (Callable[[MutableMapping[str, Any]], Awaitable[None]])

Return type:

None