@bitsinfra/fusee
    Preparing search index...

    Class StreamReader<T>

    A reader of a run's stream: yields each chunk once it is durable, in order, and ends once the stream is complete. offset is where a reader that reconnects continues; status says how the stream ended.

    Type Parameters

    • T = unknown

    Implements

    • AsyncIterable<T>
    Index
    offset: number

    The offset of the next chunk.

    run: number | undefined

    The run being read, once the first read found it (pass it back to keep reading it).

    status: string | undefined

    How the stream ended: ok, a failed step's failed, or the run's status if it ended first.

    • Returns AsyncIterator<T>