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