Rxjs merge 学习笔记

官方链接：https://rxjs-dev.firebaseapp.com/api/index/function/merge

Creates an output Observable which concurrently emits all values from every given input Observable.

创建一个输出 Observable，它同时发出来自每个给定输入 Observable 的所有值。

merge subscribes to each given input Observable (as arguments), and simply forwards (without doing any transformation) all the values from all the input Observables to the output Observable. The output Observable only completes once all input Observables have completed. Any error delivered by an input Observable will be immediately emitted on the output Observable.

merge 订阅每个给定的输入 Observable（作为参数），并简单地将所有输入 Observable 的所有值（不做任何转换）转发到输出 Observable。输出 Observable 仅在所有输入 Observable 完成后才完成。输入 Observable 传递的任何错误都将立即在输出 Observable 上发出。

看一个例子：

import { merge, fromEvent, interval } from 'rxjs';const clicks = fromEvent(document, 'click');
const timer = interval(1000);
const clicksOrTimer = merge(clicks, timer);
clicksOrTimer.subscribe(x => console.log(x));

输出：

另一个例子：

import { merge, interval } from 'rxjs';
import { take } from 'rxjs/operators';const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const timer3 = interval(500).pipe(take(10));
const concurrent = 2; // the argument
const merged = merge(timer1, timer2, timer3, concurrent);
merged.subscribe(x => console.log(x));// Results in the following:
// - First timer1 and timer2 will run concurrently
// - timer1 will emit a value every 1000ms for 10 iterations
// - timer2 will emit a value every 2000ms for 6 iterations
// - after timer1 hits its max iteration, timer2 will
//   continue, and timer3 will start to run concurrently with timer2
// - when timer2 hits its max iteration it terminates, and
//   timer3 will continue to emit a value every 500ms until it is complete

输出：

更多Jerry的原创文章，尽在：“汪子熙”:

Rxjs merge 学习笔记相关推荐

RxJs SwitchMap 学习笔记
网址:https://www.learnrxjs.io/learn-rxjs/operators/transformation/switchmap The main difference betwee ...
RxJS mergeMap 学习笔记
https://www.learnrxjs.io/learn-rxjs/operators/transformation/mergemap This operator is best used whe ...
rxjs operator学习笔记
Pipeable Operators are the kind that can be piped to Observables using the syntax observableInstance ...
Pro Android学习笔记（二九）：用户界面和控制（17）：include和merge
xml控件代码重用:include 如果我们定义一个控件,需要在不同的layout中重复使用,或者在同一个layout中重复使用,可以采用include的方式.例如定义my_button.xml如下 ...
【转】 Pro Android学习笔记（二九）：用户界面和控制（17）：include和merge
目录(?)[-] xml控件代码重用include xml控件代码重用merge 横屏和竖屏landsacpe portrait xml控件代码重用:include 如果我们定义一个控件,需要在不同的 ...
OpenCV学习笔记（三）：多通道图像分离、混合算子：split(),merge()
OpenCV学习笔记(三):多通道图像分离.混合算子:split(),merge() #include <opencv2/opencv.hpp>#define BRG_BLUE_CHANN ...
Python学习笔记---merge和concat数据合并(1)
Python学习笔记-merge和concat数据合并(1) Python学习笔记-merge和concat数据合并(2) 文章目录 Python学习笔记---merge和concat数据合并(1) ...
【学习笔记】线性代数全家桶（在编程竞赛中的应用）
整理的算法模板合集: ACM模板点我看算法全家桶系列!!! 实际上是一个全新的精炼模板整合计划目录 0x00. 矩阵 0x01. 矩阵 0x02. 矩阵的加法与数量乘法 0x03. 矩阵乘法 0x ...
SQL Server 2008/2012中SQL应用系列及BI学习笔记系列--目录索引
SQL Server 2008中的一些特性总结及BI学习笔记系列,欢迎与邀月交流. 3w@live.cn ◆0.SQL应用系列 1.SQL Server 2008中SQL增强之一:Values新用途 ...

Rxjs merge 学习笔记

Rxjs merge 学习笔记相关推荐

最新文章

热门文章