stream
stream: { observable: Observable<{ data: D; defer: Defer<any> }>; destroy: any; process: any } = createQueue<string>()
Type declaration
-
observable: Observable<{ data: D; defer: Defer<any> }>
-
destroy: function
-
Returns void
-
process: function
- process<R>(data: D): Promise<R>
-
Type parameters
Parameters
Returns Promise<R>