trinity.buffer.buffer_reader module

Reader of the buffer.

class trinity.buffer.buffer_reader.BufferReader[source]

Bases: ABC

Interface of the buffer reader.

abstract read(batch_size: int | None = None, strategy: ReadStrategy | None = None) → List[source]

Read from buffer.

abstract async read_async(batch_size: int | None = None, strategy: ReadStrategy | None = None) → List[source]

Read from buffer asynchronously.