orionis.mcp.streams.OwnedStream

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

Join source cleanup before propagating delivery errors or cancellation.

Method	`__aiter__`	Return this single-consumer iterator.
Async Method	`__anext__`	Advance one item and close when iteration ends for any reason.
Method	`__init__`	Take ownership without advancing or buffering the source.
Async Method	`_closeOwned`	Release a nested owner even when the outer iterator never started.
Async Method	`aclose`	Finish cleanup under repeated cancellation and close exactly once.
Class Variable	`__slots__`	Undocumented
Instance Variable	`_cleanup`	Undocumented
Instance Variable	`_closed`	Undocumented
Instance Variable	`_owner`	Undocumented
Instance Variable	`_source`	Undocumented

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

Return this single-consumer iterator.

Returns
`AsyncIterator[T]`	This single-consumer iterator.

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

Advance one item and close when iteration ends for any reason.

Returns
`T`	Result of the operation described above.

def __init__(self, source: AsyncIterator[T] | Iterator[T], owner: OwnedStream[object] | None = None): (source) ¶

Take ownership without advancing or buffering the source.

Parameters
source:`AsyncIterator[T] \| Iterator[T]`	Source whose values or lifecycle are consumed by this operation.
owner:`OwnedStream[object] \| None`	Value supplied for `owner`.

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

async def _closeOwned(self): (source) ¶

Release a nested owner even when the outer iterator never started.

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

overrides orionis.mcp.streams.AsyncClosable.aclose

Finish cleanup under repeated cancellation and close exactly once.

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

overrides orionis.mcp.streams.AsyncClosable.__slots__

Undocumented

_cleanup: asyncio.Future[None] | None = (source) ¶

Undocumented

Undocumented

Undocumented

Undocumented