take

签名: `take(count: number): Observable`

在完成前发出N个值(N由参数决定)。

为什么使用 `take`？

当只对开头的一组值感兴趣时，你想要的便是 take 操作符。也许你想看看当用户第一次进入页面时，用户首先点击的是什么，你想要订阅点击事件并只取首个值。举例来说，你想要观看赛跑，但其实你只对首先冲过终点的人感兴趣。此操作符很清晰明了，你想要取开头n个值。

如果想基于某个逻辑或另一个 observable 来取任意数量的值，你可以 takeUntil 或 takeWhile！

take 与 skip 是相反的，它接收起始的N个值，而 skip 会跳过起始的N个值。

示例

示例 1: 从源 observable 中取第一个值

( jsBin |
jsFiddle )

import { of } from 'rxjs/observable/of';
import { take } 'rxjs/operators';
// 发出 1,2,3,4,5
const source = of(1, 2, 3, 4, 5);
// 取第一个发出的值然后完成
const example = source.pipe(take(1));
// 输出: 1
const subscribe = example.subscribe(val => console.log(val));

示例 2: 从源 observable 中取前5个值

( jsBin |
jsFiddle )

import { interval } from 'rxjs/observable/interval';
import { take } 'rxjs/operators';
// 每1秒发出值
const interval = interval(1000);
// 取前5个发出的值
const example = interval.pipe(take(5));
// 输出: 0,1,2,3,4
const subscribe = example.subscribe(val => console.log(val));

示例 3: 取得首次点击的坐标

(jsFiddle)

<div id="locationDisplay">
  Where would you click first?
</div>

import { fromEvent } from 'rxjs/observable/fromEvent';
import { take, tap } 'rxjs/operators';
const oneClickEvent = fromEvent(document, 'click').pipe(
    take(1),
    tap(v => {
      document.getElementById('locationDisplay').innerHTML
        = `Your first click was on location ${v.screenX}:${v.screenY}`;
    })
  )
const subscribe = oneClickEvent.subscribe();