Class BusReader<T>

Reader, which stores all events into internal queue. Then all events can be awaited.

Unlike busReadSingleEvent requires closing and can't omit any event being triggered while current one is being handled.

Type Parameters

  • T

Hierarchy

  • BusReader

Constructors

Properties

eventQueue: Queue<T> = ...
innerIsClosed: boolean = false
latePromiseQueue: Queue<[((e) => void), ((e) => void)]> = ...

Accessors

Methods

  • Returns event if one was already enqueued and drops it from queue. Returns null otherwise.

    Always returns as fast as possible.

    Note: running it in infinite loop will cause that loop to never end, as it does not allow JS fiber switching, so that another fiber may enqueue that event.

    Returns undefined | T

Generated using TypeDoc