rxjs里merge operators的用法

stream是lazy的，no subscription, no calculation occurs.

作用：Flattens multiple Observables together by blending their values into one Observable.

例子：

 const clicks = fromEvent(document, 'click');const timer = interval(1000);const clicksOrTimer = merge(clicks, timer);clicksOrTimer.subscribe(x => console.log('jerry: ' + x));

测试结果：每隔1秒钟Observable emit一个值递增的整数。然后如果我点击UI，会显示一个[object MouseEvent]的事件：

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(1000).pipe(take(10));
const timer3 = interval(1000).pipe(take(10));
const concurrent = 3; // the argument
const merged = merge(timer1, timer2, timer3, concurrent);
merged.subscribe(x => console.log('diablo: '+ x));

每秒同时emit 三个值：

要获取更多Jerry的原创文章，请关注公众号"汪子熙":

rxjs里merge operators的用法相关推荐

rxjs里switchMap operators的用法
switchMap相关文章 rxjs里switchMap operators的用法通过rxjs的一个例子, 来学习SwitchMap的使用方法 rxjs switchMap的实现原理 rxjs的ma ...
rxjs里concatMap operators的用法
Projects each source value to an Observable which is merged in the output Observable, in a serialize ...
rxjs里delay operators的用法
Delays the emission of items from the source Observable by a given timeout or until a given Date. 例子 ...
rxjs里debounceTime operators的用法
Emits a value from the source Observable only after a particular time span has passed without anothe ...
rxjs里withLatestFrom operators的用法
Combines the source Observable with other Observables to create an Observable whose values are calcu ...
rxjs里combineLatest operators的用法
Whenever any input Observable emits a value, it computes a formula using the latest values from all ...
rxjs里scan operators的用法
Applies an accumulator function over the source Observable, and returns each intermediate result, wi ...
rxjs里mapTo operators的用法
和map工作原理类似,只不过emit的是一个常数. Like map, but it maps every source value to the same output value every ti ...
Rxjs 里 filter(Boolean) 的用法
StackOverflow 上的讨论: https://stackoverflow.com/questions/53953015/using-rxjs-with-filterboolean-for-q ...

rxjs里merge operators的用法

rxjs里merge operators的用法相关推荐

最新文章

热门文章