`viam.streams`

Module Contents

Classes

`Stream`
`StreamReader`
`StreamSource`
`StreamWithIterator`

Attributes

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]