• Parameters

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