- 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<{
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>;
}>
Wrap a Publisher to record all the values to chain storage.