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

Type Parameters

  • T

Properties

Properties

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.