node.js - 在 catchError 中获取源值 - RxJS

Question

我需要获取开始执行我的 Observable 的源值。例如：

this.queue = new Subject<Task>();
this.queue.pipe(
    mergeMap(/* ... */),
    mergeMap(/* ... */),
    catchError(<get error and source here>)
);

function addToQueue(source: Task): void {
   this.queue.next(source);
}

那可能吗？

标签： node.jstypescriptrxjs