RxJS take

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

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

參量

returns

MonoTypeOperatorFunction<T>：一個 Observable，它僅count 發(fā)出源 Observable 發(fā)出的第一個值，或者如果源發(fā)出的count值少于該值，則從該源發(fā)出的所有值。

投擲

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

描述

count從源中獲取第一個值，然后完成。

take返回一個 Observable，它僅count發(fā)出源 Observable 發(fā)出的第一個值。如果源發(fā)出的count值少于值，則將發(fā)出其所有值。之后，無論源是否完成，它都會完成。

例

采取無限的 1 秒間隔的前 5 秒

import { interval } from 'rxjs';
import { take } from 'rxjs/operators';


const intervalCount = interval(1000);
const takeFive = intervalCount.pipe(take(5));
takeFive.subscribe(x => console.log(x));


// Logs:
// 0
// 1
// 2
// 3
// 4

也可以看看

• takeLast
• takeUntil
• takeWhile
• skip