orionis.mcp.transport.http.

THE ORIONIS API

Build with clarity.

Explore the building blocks of an async-first Python framework. Every module, class, and method — connected, searchable, and ready to build with.

class documentation

class _EventFrames(AsyncClosable): (source)

Own an MCP byte iterator even if the HTTP stream is never started.

Method	`__aiter__`	Return this owned, single-use event source.
Async Method	`__anext__`	Frame one message only when the native HTTP adapter is ready.
Method	`__init__`	Transfer iterator and admission-slot ownership to the response.
Async Method	`aclose`	Close the producer and release admission before scope disposal.
Class Variable	`__slots__`	Undocumented
Instance Variable	`_release`	Undocumented
Instance Variable	`_source`	Undocumented

def __aiter__(self) -> Self: (source) ¶

Return this owned, single-use event source.

Returns
`Self`	This owned, single-use event source.

async def __anext__(self) -> ServerSentEvent: (source) ¶

Frame one message only when the native HTTP adapter is ready.

Returns
`ServerSentEvent`	Result of the operation described above.

def __init__(self, source: AsyncIterator[bytes], release: Callable[[], None]): (source) ¶

Transfer iterator and admission-slot ownership to the response.

Parameters
source:`AsyncIterator[bytes]`	Source whose values or lifecycle are consumed by this operation.
release:`Callable[[], None]`	Value supplied for `release`.

Returns
`None`	Complete the documented operation without returning a value.

overrides orionis.mcp.streams.AsyncClosable.aclose

Close the producer and release admission before scope disposal.

Returns
`None`	Complete the documented operation without returning a value.

overrides orionis.mcp.streams.AsyncClosable.__slots__

Undocumented

Undocumented

_source: AsyncIterator[bytes] | None = (source) ¶

Undocumented