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 _Broadcast: (source)
Constructor: _Broadcast(manager, hub, recipients, encoded)
Share one immutable encoded payload per codec among bounded workers.
| Method | __init__ |
Prepare a shared recipient iterator and delivery counters. |
| Async Method | run |
Drain recipients while respecting each connection's backpressure. |
| Class Variable | __slots__ |
Undocumented |
| Instance Variable | encoded |
Undocumented |
| Instance Variable | failed |
Undocumented |
| Instance Variable | hub |
Undocumented |
| Instance Variable | manager |
Undocumented |
| Instance Variable | recipients |
Undocumented |
| Instance Variable | sent |
Undocumented |
def __init__(self, manager:
IConnectionManager, hub: type[, recipients: tuple[, encoded: dict[):
(source)
¶
Prepare a shared recipient iterator and delivery counters.
| Parameters | |
manager:IConnectionManager | Registry used to recheck availability immediately before sending. |
hub:type[Hub] | Hub namespace restricting all recipients. |
recipients:tuple[str, ...] | Snapshot of recipient identifiers; no connections are retained. |
encoded:dict[str, str | bytes] | Immutable frame payloads, encoded once per selected codec. |
| Returns | |
None | Store delivery inputs and initialize successful and failed counts. |
Drain recipients while respecting each connection's backpressure.
| Returns | |
None | Count failures independently; task cancellation propagates. |