RxJS takeLast

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

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

參量

returns

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

投擲

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

描述

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

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

例

取具有多個(gè)值的 Observable 的最后3個(gè)值

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