Rxjs TakeUntil 操作符内容梳理总结
TakeUntil 的官方文档对这个操作符的解释是：
Emit values until provided observable emits.
即它可以被赋予另一个起锚定作用的 Observable，当该锚定 Observable emit 值时，原始的 Observable 就停止发射值，进入 complete 操作。
看一个实际的例子：
import { interval, timer } from 'rxjs';
import { takeUntil } from 'rxjs/operators';
//emit value every 1s
const source = interval(1000);
//after 5 seconds, emit value
const timer$ = timer(5000);
//when timer emits after 5s, complete source
const example = source.pipe(takeUntil(timer$));
//output: 0,1,2,3
const subscribe = example.subscribe(val => console.log(val));source Observable 每个1秒的时间间隔，发射一个从 0 开始递增间隔为 1 的整数序列。
我们构造了一个 timer Observable，超时时间间隔为 5 秒，也就是说，在第五秒时，该 Observable 会发送一个值。这个 timer Observable 传入 takeUntil，作为一个 notification Observable，五秒钟之后，source Observable 就会停止发射整数。
最后上述程序执行的输出：4 秒之内打印 0～4，然后结束。
另一个例子：
const interval = interval(1000); const clicks = fromEvent(document, 'click'); const result = interval.pipe(takeUntil(clicks)); result.subscribe(x => console.log(x));
这个例子里，interval 作为原始的 Observable，clicks 作为 notification Observable，整个程序的表现形式是，每个 1 秒有一个递增1的整数序列打印，直至页面发生点击事件时，原始 interval Observable 终止。
看另一个例子：
// RxJS v6+
import { interval } from 'rxjs/observable/interval';
import { takeUntil, filter, scan, map, withLatestFrom } from 'rxjs/operators';
//emit value every 1s
const source = interval(1000);
//is number even?
const isEven = val => val % 2 === 0;
//only allow values that are even
const evenSource = source.pipe(filter(isEven));
//keep a running total of the number of even numbers out
const evenNumberCount = evenSource.pipe(scan((acc, _) => acc + 1, 0));
//do not emit until 5 even numbers have been emitted
const fiveEvenNumbers = evenNumberCount.pipe(filter(val => val > 5));
const example = evenSource.pipe(
//also give me the current even number count for display
withLatestFrom(evenNumberCount),
map(([val, count]) => `Even number (${count}) : ${val}`),
//when five even numbers have been emitted, complete source observable
takeUntil(fiveEvenNumbers)
);
/*
Even number (1) : 0,
Even number (2) : 2
Even number (3) : 4
Even number (4) : 6
Even number (5) : 8
*/
const subscribe = example.subscribe(val => console.log(val));我们逐行分析这个例子的逻辑：
const evenSource = source.pipe(filter(isEven));
产生一个每隔1秒发射一个偶数的 Observable.
const evenNumberCount = evenSource.pipe(scan((acc, _) => acc + 1, 0));
对产生的偶数的个数进行累加。
const fiveEvenNumbers = evenNumberCount.pipe(filter(val => val > 5));
当产生的偶数个数大于 5 时，发射值。这个 Observable 作为 takeUntil 的 notification Observable 使用。
const example = evenSource.pipe(
//also give me the current even number count for display
withLatestFrom(evenNumberCount),
map(([val, count]) => `Even number (${count}) : ${val}`),
//when five even numbers have been emitted, complete source observable
takeUntil(fiveEvenNumbers)
);- 使用 eventSource 和 eventNumberCount，通过
withLatestFrom将两个 Observable 进行连接，从而在 map Operator 里，可以同时打印出当前发射的偶数值和偶数总量。通过 takeUntil 传入一个只有在偶数总数个数大于 5 时才发射值的 Observable，可以做到偶数总数大于 5 之后，让 interval 停止值的发送。
最后的执行效果：
到此这篇关于Rxjs TakeUntil 操作符内容梳理总结的文章就介绍到这了,更多相关Rxjs TakeUntil 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文给大家介绍JavaScript蒙板(model)功能的简单实现代码，创建一个蒙板, 设置蒙板的堆叠顺序保证能将其它元素盖住，感兴趣的朋友可以参考下实现代码2016-08-08
下面小编就为大家带来一篇js中Number数字数值运算后值不对的解决方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-02-02
这篇文章主要介绍了Bootstrap组合上、下拉框的简单实现代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-03-03
本文主要介绍了JS验证不重复验证码的示例代码。具有很好的参考价值，下面跟着小编一起来看下吧2017-02-02
这篇文章主要介绍了javascript深拷贝的原理与实现方法,简单分析了值传递和引用传递的原理与实现方法,并结合实例形式给出了深拷贝的具体实现技巧,需要的朋友可以参考下2017-04-04
BootStrap Table 分页后重新搜索问题的解决办法
这篇文章主要介绍了BootStrap Table 分页后重新搜索问题的解决办法,自定义搜索且有分页功能,比如搜索产品名的功能。小编给大家带来了关键代码，非常不错，需要的朋友可以参考下2016-08-08
这篇文章主要介绍了JavaScript中的find()方法和返回数据的内存指向,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-04-04
这篇文章主要介绍了微信小程序上传图片到服务器的实例代码，在文章给大家补充介绍了微信小程序上传一或多张图片 的方法，本文给大家介绍的非常详细，具有参考借鉴加载,需要的朋友可以参考下2017-11-11
今天小编就为大家分享一篇layui前端时间戳转化实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-11-11
这篇文章主要为大家详细介绍了微信小程序使用视频播放器video组件，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-04-04
最新评论