Function prepareDurablePublishKit
- prepareDurablePublishKit(baggage, kindName): ((...args: [options: {
valueDurability: undefined | "mandatory";
}]) => GuardedKit<{
publisher: {
fail(reason: any): void;
finish(finalValue: any): void;
publish(value: any): void;
};
subscriber: {
getUpdateSince(updateCount: any): any;
subscribeAfter(publishCount?: bigint): Promise<any>;
};
}>) Returns ((...args: [options: {
valueDurability: undefined | "mandatory";
}]) => GuardedKit<{
publisher: {
fail(reason: any): void;
finish(finalValue: any): void;
publish(value: any): void;
};
subscriber: {
getUpdateSince(updateCount: any): any;
subscribeAfter(publishCount?: bigint): Promise<any>;
};
}>)
- (...args): GuardedKit<{
publisher: {
fail(reason: any): void;
finish(finalValue: any): void;
publish(value: any): void;
};
subscriber: {
getUpdateSince(updateCount: any): any;
subscribeAfter(publishCount?: bigint): Promise<any>;
};
}> Parameters
Rest
...args: [options: {
valueDurability: undefined | "mandatory";
}]
Returns GuardedKit<{
publisher: {
fail(reason: any): void;
finish(finalValue: any): void;
publish(value: any): void;
};
subscriber: {
getUpdateSince(updateCount: any): any;
subscribeAfter(publishCount?: bigint): Promise<any>;
};
}>