RxJS takeLast

僅count發(fā)出源 Observable 發(fā)出的最后一個值。

takeLast<T>(count: number): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：一個 Observable，最多發(fā)出源 Observable 發(fā)出的最后一個計數(shù)值。

投擲

ArgumentOutOfRangeError使用時takeLast(i)，如果，它將 ArgumentOutOrRangeError 傳遞給觀察者的error回調(diào)i < 0。

描述

記住最新的 count值，然后僅在源完成時才發(fā)出這些值。

takeLast返回一個 Observable，它最多count發(fā)出源 Observable 發(fā)出的最后一個值。如果源發(fā)出的count 值少于值，則將發(fā)出其所有值。該操作員必須等到 complete從源發(fā)出通知后，才能next 在輸出 Observable 上發(fā)射值，因為否則無法知道是否在源上發(fā)射更多的值。因此，所有值都將同步發(fā)出，然后發(fā)出完整的通知。

例

取具有多個值的 Observable 的最后3個值

import { range } from 'rxjs';
import { takeLast } from 'rxjs/operators';


const many = range(1, 100);
const lastThree = many.pipe(takeLast(3));
lastThree.subscribe(x => console.log(x));

也可以看看

• take
• takeUntil
• takeWhile
• skip