take
Emits only the first count
values emitted by the source Observable.
Takes the first count
values from the source, then
completes.
take
returns an Observable that emits only the first count
values emitted
by the source Observable. If the source emits fewer than count
values then
all of its values are emitted. After that, it completes, regardless if the
source completes.
Example
Take the first 5 seconds of an infinite 1-second interval Observable
import { interval, take } from 'rxjs';
const intervalCount = interval(1000);
const takeFive = intervalCount.pipe(take(5));
takeFive.subscribe(x => console.log(x));
// Logs:
// 0
// 1
// 2
// 3
// 4