interface IReceiver {
    subscribe: (<T>(decoders, callback) => Unsubscribe | Promise<Unsubscribe>);
    toSubscriptionIterator: (<T>(decoders) => Promise<IAsyncIterator<T>>);
}

Properties

subscribe: (<T>(decoders, callback) => Unsubscribe | Promise<Unsubscribe>)

Type declaration

toSubscriptionIterator: (<T>(decoders) => Promise<IAsyncIterator<T>>)

Type declaration

Generated using TypeDoc