use makeStoredSubscriber

Begin iterating the source, storing serialized iteration values. If the storageNode's setValue operation rejects, the iteration will be terminated.

Returns a StoredSubscription that can be used by a client to directly follow the iteration themselves, or obtain information to subscribe to the stored data out-of-band.

  • Type Parameters

    • T

    Parameters

    • subscription: Subscription<T>
    • OptionalstorageNode: null | ERemote<StorageNode>
    • Optionalmarshaller: ERemote<{
          fromCapData: ((...args: [data: CapData<unknown>]) => any);
          serialize: ((...args: [val: Passable]) => ERef<CapData<unknown>>);
          toCapData: ((...args: [val: Passable]) => ERef<CapData<unknown>>);
          unserialize: ((...args: [data: CapData<unknown>]) => any);
      }> = ...

    Returns StoredSubscription<T>