Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Stream<T>

Stream implements an Asynchronous Iterable over messages received from a topic. As such can be used with constructs like for-await-of, yield*, array destructing, etc.

Type parameters

  • T

Hierarchy

  • Stream

Index

Constructors

Properties

Methods

Constructors

constructor

  • new Stream<T>(client: Client, topics: string[], decoder: MessageDecoder<T>, contentTopicUpdater?: ContentTopicUpdater<T>, onConnectionLost?: OnConnectionLostCallback): Stream<T>

  • Type parameters

    • T

    Parameters

    • client: Client
    • topics: string[]
    • decoder: MessageDecoder<T>
    • Optional contentTopicUpdater: ContentTopicUpdater<T>
    • Optional onConnectionLost: OnConnectionLostCallback

    Returns Stream<T>

Properties

callback

callback: undefined | ((env: Envelope) => Promise<void>)

client

client: Client

messages

messages: T[]

Optional onConnectionLost

onConnectionLost?: OnConnectionLostCallback

resolvers

resolvers: ((value: IteratorResult<T, any>) => void)[]

topics

topics: string[]

Optional unsubscribeFn

unsubscribeFn?: UnsubscribeFn

Methods

[asyncIterator]

  • [asyncIterator](): AsyncIterableIterator<T>

next

  • next(): Promise<IteratorResult<T, any>>

return

  • return(): Promise<IteratorResult<T, any>>

Static create

  • create<T>(client: Client, topics: string[], decoder: MessageDecoder<T>, contentTopicUpdater?: ContentTopicUpdater<T>, onConnectionLost?: OnConnectionLostCallback): Promise<Stream<T>>

  • Type parameters

    • T

    Parameters

    • client: Client
    • topics: string[]
    • decoder: MessageDecoder<T>
    • Optional contentTopicUpdater: ContentTopicUpdater<T>
    • Optional onConnectionLost: OnConnectionLostCallback

    Returns Promise<Stream<T>>

Generated using TypeDoc