darcyai.input.input_stream

InputStream Objects

class InputStream()

Base class for reading input from a stream.

Examples

>>> from darcyai.input.input_stream import InputStream
>>> from darcyai.stream_data import StreamData

>>> class MyInputStream(InputStream):
...     def stream(self):
...         yield StreamData("data", 1234567890)

>>>     def stop(self):
...         pass

stream

def stream() -> Iterable[StreamData]

Returns a generator that yields a stream of input.

Returns

A generator that yields a stream of input.

stop

def stop() -> None

Stops the stream.