Stream
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
| Name |
|---|
T |
Constructors
constructor
• new Stream<T>(client, topics, messageTransformer, messageFilter?, contentTopicUpdater?)
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
client | Client |
topics | string[] |
messageTransformer | MessageTransformer<T> |
messageFilter? | MessageFilter |
contentTopicUpdater? | ContentTopicUpdater |
Defined in
Properties
callback
• callback: undefined | (env: Envelope) => Promise<void>
Defined in
client
• client: Client
Defined in
messages
• messages: T[]
Defined in
resolvers
• resolvers: (value: IteratorResult<T, any>) => void[]
Defined in
topics
• topics: string[]
Defined in
unsubscribeFn
• Optional unsubscribeFn: UnsubscribeFn
Defined in
Methods
[asyncIterator]
▸ [asyncIterator](): AsyncIterableIterator<T>
Returns
AsyncIterableIterator<T>
Defined in
next
▸ next(): Promise<IteratorResult<T, any>>
Returns
Promise<IteratorResult<T, any>>
Defined in
return
▸ return(): Promise<IteratorResult<T, any>>
Returns
Promise<IteratorResult<T, any>>
Defined in
create
▸ Static create<T>(client, topics, messageTransformer, messageFilter?, contentTopicUpdater?): Promise<Stream<T>>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
client | Client |
topics | string[] |
messageTransformer | MessageTransformer<T> |
messageFilter? | MessageFilter |
contentTopicUpdater? | ContentTopicUpdater |
Returns
Promise<Stream<T>>
