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

  • Parameters

    • baggage: Baggage
    • marshaller: ERemote<Marshaller>

    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>;
        }>