ORIONIS API REFERENCE

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.

Explore modules View classes

orionis.mcp.subscriptions.event_bus.InMemoryMcpEventBus

class documentation

class InMemoryMcpEventBus(IMcpEventBus): (source)

Constructor: InMemoryMcpEventBus(buffer_size, max_listeners)

View In Hierarchy

Coalesce duplicate changes and close overloaded listeners gracefully.

Method __init__ Set finite listener and per-listener buffer budgets.
Method listen Register synchronously so publication cannot race acknowledgment.
Async Method publish Publish without awaiting a slow client or creating producer tasks.
Method remove Release an iterator even if it was closed before its first read.
Async Method shutdown Stop admission and wake all consumers to send graceful completion.
Class Variable __slots__ Undocumented
Instance Variable _closed Undocumented
Instance Variable _listeners Undocumented
Instance Variable _max_listeners Undocumented
Instance Variable _size Undocumented
Property listener_count Expose aggregate lifecycle diagnostics, without subscriber identity.
def __init__(self, buffer_size: int = 64, max_listeners: int = 1024): (source)

Set finite listener and per-listener buffer budgets.

Parameters
buffer_size:intValue supplied for buffer_size.
max_listeners:intValue supplied for max_listeners.
Returns
NoneComplete the documented operation without returning a value.
def listen(self, server: type, filters: SubscriptionFilter) -> AsyncIterator[Change]: (source)
overrides orionis.mcp.contracts.event_bus.IMcpEventBus.listen

Register synchronously so publication cannot race acknowledgment.

Parameters
server:typeValue supplied for server.
filters:SubscriptionFilterValue supplied for filters.
Returns
AsyncIterator[Change]Result of the operation described above.
async def publish(self, server: type, method: str, uri: str | None = None): (source)
overrides orionis.mcp.contracts.event_bus.IMcpEventBus.publish

Publish without awaiting a slow client or creating producer tasks.

Parameters
server:typeValue supplied for server.
method:strValue supplied for method.
uri:str | NoneValue supplied for uri.
Returns
NoneComplete the documented operation without returning a value.
def remove(self, listener: _Listener): (source)

Release an iterator even if it was closed before its first read.

Parameters
listener:_ListenerValue supplied for listener.
Returns
NoneComplete the documented operation without returning a value.
async def shutdown(self): (source)
overrides orionis.mcp.contracts.event_bus.IMcpEventBus.shutdown

Stop admission and wake all consumers to send graceful completion.

Returns
NoneComplete the documented operation without returning a value.
__slots__: tuple[str, ...] = (source)
overrides orionis.mcp.contracts.event_bus.IMcpEventBus.__slots__

Undocumented

_closed: bool = (source)

Undocumented

_listeners: set[_Listener] = (source)

Undocumented

_max_listeners = (source)

Undocumented

_size = (source)

Undocumented

listener_count: int = (source)

Expose aggregate lifecycle diagnostics, without subscriber identity.

Returns
intResult of the operation described above.