Returns a Subscription which processes received values via the configured worker(s) and then passes values received back from the worker(s) downstream, thereby allowing workers to be used transparently for stream processing.
remarks
Multiple worker instances are supported for concurrent processing. See the TunnelOpts for details.
Returns a Subscription which processes received values via the configured worker(s) and then passes values received back from the worker(s) downstream, thereby allowing workers to be used transparently for stream processing.
Multiple worker instances are supported for concurrent processing. See the TunnelOpts for details.
Also see forkJoin and postWorker.