Type Alias EachTopic<T>

EachTopic<T>: {
subscribeAfter: ((publishCount?: bigint) => Promise<PublicationRecord<T>>);
}

Type Parameters

T

Type declaration

subscribeAfter: ((publishCount?: bigint) => Promise<PublicationRecord<T>>)
Returns a promise for a "current" PublicationRecord (referencing its immediate successor via a tail promise) that is later than the provided publishCount. Used to make forward-lossless ("each") iterators.
- - (publishCount?): Promise<PublicationRecord<T>>
  - Parameters
    - OptionalpublishCount: bigint
    Returns Promise<PublicationRecord<T>>