Function makeStoredPublishKit

Deprecated

incompatible with durability; instead handle vstorage ephemerally on a durable PublishKit

Like makePublishKit this makes a { publisher, subscriber } pair for doing efficient distributed pub/sub supporting both "each" and "latest" iteration of published values.

What's different is subscriber tees records, writing out to storageNode.

  • makeStoredPublishKit<T>(storageNode, marshaller): StoredPublishKit<T>

  • Type Parameters

    • T = unknown

    Parameters

    • storageNode: ERemote<StorageNode>
    • marshaller: 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 StoredPublishKit<T>

Settings

Member Visibility