viam.streams

Attributes

StreamType

Classes

Stream

StreamReader

StreamSource

StreamWithIterator

Module Contents

viam.streams.StreamType
class viam.streams.Stream[source]

Bases: Protocol[StreamType]

async next() StreamType[source]
__aiter__() collections.abc.AsyncIterator[source]
async __anext__() StreamType[source]
class viam.streams.StreamReader[source]

Bases: Protocol[StreamType]

async read() StreamType[source]
class viam.streams.StreamSource[source]

Bases: Protocol[StreamType]

async stream() Stream[StreamType][source]
class viam.streams.StreamWithIterator(stream: collections.abc.AsyncIterator[StreamType])[source]

Bases: Stream[StreamType]

async next() StreamType[source]
__aiter__()[source]
async __anext__() StreamType[source]