Documentation
    Preparing search index...

    Interface IReceiver

    will be replaced in next version

    interface IReceiver {
        subscribeWithUnsubscribe: SubscribeWithUnsubscribe;
        toSubscriptionIterator: <T extends IDecodedMessage>(
            decoders: IDecoder<T> | IDecoder<T>[],
        ) => Promise<IAsyncIterator<T>>;
    }
    Index

    Properties

    subscribeWithUnsubscribe: SubscribeWithUnsubscribe
    toSubscriptionIterator: <T extends IDecodedMessage>(
        decoders: IDecoder<T> | IDecoder<T>[],
    ) => Promise<IAsyncIterator<T>>