- prepareRecorder(baggage, marshaller): ((...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>;
}>) 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>;
}>
Wrap a Publisher to record all the values to chain storage.