RxJS tap

對源 Observable 上的每個發(fā)射執(zhí)行副作用，但返回與源相同的 Observable。

tap<T>(nextOrObserver?: NextObserver<T> |ErrorObserver<T> | CompletionObserver<T> | ((x: T) => void), error?: (e: any) => void, complete?: () => void): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：與源相同的 Observable，但為每個項目運行指定的 Observer 或 callback。

描述

攔截源上的每個發(fā)射并運行一個函數(shù)，但是只要不發(fā)生錯誤，就返回與源相同的輸出。

返回源 Observable 的鏡像 Observable，但已對其進行了修改，以便調用提供的 Observer 對源發(fā)出的每個值，錯誤和完成執(zhí)行副作用。在上述 Observer 或處理程序中引發(fā)的任何錯誤都將沿著輸出 Observable 的錯誤路徑安全地發(fā)送。

該運算符可用于調試 Observable 的正確值或執(zhí)行其他副作用。

注意：這subscribe與 Observable 上的有所不同。如果tap未訂閱由返回的 Observable，則 Observer 指定的副作用將永遠不會發(fā)生。tap因此，僅監(jiān)視現(xiàn)有執(zhí)行，就不會觸發(fā)執(zhí)行subscribe。

例

將每次點擊映射到該點擊的 clientX 位置，同時記錄點擊事件

import { fromEvent } from 'rxjs';
import { tap, map } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const positions = clicks.pipe(
  tap(ev => console.log(ev)),
  map(ev => ev.clientX),
);
positions.subscribe(x => console.log(x));

超載

tap(next: null, error: null, complete: () => void): MonoTypeOperatorFunction<T>

returnsMonoTypeOperatorFunction<T> tap(next: null, error: (error: any) => void, complete?: () => void): MonoTypeOperatorFunction<T>

returnsMonoTypeOperatorFunction<T>

tap(next: (value: T) => void, error: null, complete: () => void): MonoTypeOperatorFunction<T>

returnsMonoTypeOperatorFunction<T>

tap(next?: (x: T) => void, error?: (e: any) => void, complete?: () => void): MonoTypeOperatorFunction<T>

returnsMonoTypeOperatorFunction<T>

tap(observer: PartialObserver<T>): MonoTypeOperatorFunction<T>

returnsMonoTypeOperatorFunction<T>

也可以看看

• map
• Observable