Class Stream<T, ClientType>

constructor

• new Stream<T, ClientType>(client, topics, decoder, contentTopicUpdater?, onConnectionLost?): Stream<T, ClientType>

• Type Parameters

  • T
  • ClientType = any

  Parameters

  • client: Client<ClientType>
  • topics: string[]
  • decoder: MessageDecoder<T>
  • OptionalcontentTopicUpdater: ContentTopicUpdater<T>
  • OptionalonConnectionLost: OnConnectionLostCallback

  Returns Stream<T, ClientType>

callback

client

messages

OptionalonConnectionLost

resolvers

OptionalsubscriptionManager

topics

[asyncIterator]

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

• Returns AsyncIterableIterator<T, any, any>

next

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

• Returns Promise<IteratorResult<T, any>>

return

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

• Returns Promise<IteratorResult<T, any>>

Staticcreate

• create<T, ClientType>(client, topics, decoder, contentTopicUpdater?, onConnectionLost?): Promise<Stream<T, ClientType>>

• Type Parameters

  • T
  • ClientType = string

  Parameters

  • client: Client<ClientType>
  • topics: string[]
  • decoder: MessageDecoder<T>
  • OptionalcontentTopicUpdater: ContentTopicUpdater<T>
  • OptionalonConnectionLost: OnConnectionLostCallback

  Returns Promise<Stream<T, ClientType>>