orionis.mcp.subscriptions.event_bus.

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 _Subscription(AsyncClosable): (source)

An explicitly closable iterator, including before first iteration.

Method	`__aiter__`	Return the subscription iterator.
Async Method	`__anext__`	Wait without losing wakeups; propagate cancellation after cleanup.
Method	`__init__`	Own exactly one listener registration.
Async Method	`aclose`	Release request-owned resources immediately.
Class Variable	`__slots__`	Undocumented
Instance Variable	`_bus`	Undocumented
Instance Variable	`_listener`	Undocumented

def __aiter__(self) -> AsyncIterator[Change]: (source) ¶

Return the subscription iterator.

Returns
`AsyncIterator[Change]`	The subscription iterator.

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

Wait without losing wakeups; propagate cancellation after cleanup.

Returns
`Change`	Result of the operation described above.

def __init__(self, bus: InMemoryMcpEventBus, listener: _Listener): (source) ¶

Own exactly one listener registration.

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

overrides orionis.mcp.streams.AsyncClosable.aclose

Release request-owned resources immediately.

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

overrides orionis.mcp.streams.AsyncClosable.__slots__

Undocumented

Undocumented

Undocumented