Wrap a Publisher to record all the values to chain storage.

  • Parameters

    • baggage: Baggage
    • 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 ((...args: [publisher: Publisher<unknown>, storageNode: Remote<StorageNode>, valueShape: TypedPattern<any>]) => Guarded<{
        getStorageNode(): Remote<StorageNode>;
        getStoragePath(): Promise<string>;
        write(value: any): Promise<void>;
        writeFinal(value: any): Promise<void>;
    }>)

      • (...args): Guarded<{
            getStorageNode(): Remote<StorageNode>;
            getStoragePath(): Promise<string>;
            write(value: any): Promise<void>;
            writeFinal(value: any): Promise<void>;
        }>
      • Parameters

        • Rest...args: [publisher: Publisher<unknown>, storageNode: Remote<StorageNode>, valueShape: TypedPattern<any>]

        Returns Guarded<{
            getStorageNode(): Remote<StorageNode>;
            getStoragePath(): Promise<string>;
            write(value: any): Promise<void>;
            writeFinal(value: any): Promise<void>;
        }>