IterableEachTopic<T>: ForkableAsyncIterable<T, T> & EachTopic<T>

An EachTopic with default asyncIterable behaviour.

NOTE: the publication records and iterators returned by this object are ephemeral and will be severed during upgrade. A caller should use subscribeEach to wrap this topic in a local iterable which automatically attempts to reconnect upon being severed.

Type Parameters

  • T