RxJS tap

對源 Observable 上的每個(gè)發(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，但為每個(gè)項(xiàng)目運(yùn)行指定的 Observer 或 callback。

描述

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

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

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

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

例

將每次點(diǎn)擊映射到該點(diǎn)擊的 clientX 位置，同時(shí)記錄點(diǎn)擊事件

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