Interface Sub<T>

Basic interface to a Subscription type

Type Parameters

  • T

Hierarchy

  • AsyncIterable<T>
    • Sub

Properties

closed

Methods

[asyncIterator] drain getMax getPending getProcessed getReceived getSubject isClosed isDraining unsubscribe

Properties

closed

closed: Promise<void>

A promise that resolves when the subscription closes

Methods

[asyncIterator]

  • [asyncIterator](): AsyncIterator<T, any, undefined>

  • Returns AsyncIterator<T, any, undefined>

drain

  • Drain the subscription, closing it after processing all messages currently in flight for the client. Returns a promise that resolves when the subscription finished draining.

    Returns Promise<void>

getMax

  • Return the max number of messages before the subscription will unsubscribe.

    Returns number

getPending

  • Returns the number of messages that are pending processing. Note that this is method is only valid for iterators.

    Returns number

getProcessed

  • Returns the number of messages that have been processed by the subscription.

    Returns number

getReceived

  • Returns the number of messages received by the subscription.

    Returns number

getSubject

  • Returns the subject that was used to create the subscription.

    Returns string

isClosed

  • Returns true if the subscription is closed.

    Returns boolean

isDraining

  • Returns true if the subscription is draining.

    Returns boolean

unsubscribe

  • Stop the subscription from receiving messages. You can optionally specify that the subscription should stop after the specified number of messages have been received. Note this count is since the lifetime of the subscription.

    Parameters

    • Optional max: number

    Returns void

Settings

Member Visibility

Theme

Generated using TypeDoc