Categories: RxJS教程

RxJS：公用程序运算符tap

该运算符的输出将与可观察的源相同，可用于将值从可观察的日志记录到用户。

句法

tap(observer, error, complete):Observable

参量

observer -（可选）与可观察的来源相同。

error -（可选）错误方法（如果发生任何错误）。

complete-（可选）complete()方法将在任务完成时被调用。

返回值

它返回的可观察对象与可通过回调函数观察的源相同。

例

import { of } from 'rxjs';
import { tap, filter } from 'rxjs/operators';

let list1 = of(1, 2, 3, 4, 5, 6);
let final_val = list1.pipe(
   tap(x => console.log("From tap() =" + x),
      e => console.log(e),
      () => console.log("Task complete")),
   filter(a => a % 2 === 0)
);
final_val.subscribe(x => console.log("Only Even numbers=" + x));