towhee.engine.operator_io.reader.ReaderBase¶

class towhee.engine.operator_io.reader.ReaderBase[source]¶

Bases: ABC

The reader base class. The read() could be blocking or non-blocking function, if it’s a blocking function, the runner may be blocked. When need to stop the graph, we call close to interrupting it.