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.

  • Type Parameters

    • T = unknown

    Parameters

    • storageNode: ERef<StorageNode>
    • marshaller: ERef<{
          fromCapData: FromCapData<unknown>;
          serialize: ToCapData<unknown>;
          toCapData: ToCapData<unknown>;
          unserialize: FromCapData<unknown>;
      }>

    Returns StoredPublishKit<T>