javaee论坛

普通会员

225648

帖子

335

回复

349

积分

楼主
发表于 2017-08-27 17:18:14 | 查看: 513 | 回复: 0


  merge操作的目的是将两个独立序列,合成一个序列。原本序列1随着时间的前进,在100ms时发射a,在200ms时发射b,300ms时发射c,它的订阅者在400ms将受到abc三个值;序列2在150ms时发射d,250ms时发射e,350ms时发射f,它的订阅者在400ms内收到def三个值。而merge之后的新序列将在400ms内收到abcdef(注意顺序)。
 
  常用操作符的理解:
Observable.range:发射一定数量值得序列。
Observable.toArray: 在序列完成时将所有发射值转换为一个数组。
Observable.flatMap: 将原始序列流中的元素转化为一个新的序列流,并将这个新的序列流merge到原来的序列中元素的位置。
Observable.startWith: 它会设置Observable序列的第一个值
Observable.combineLatest: 类似于promiseAll,在所有序列有结果后才会执行
Observable.scan: 将序列中每次发射的值可以做聚合,与reduce类似,reduce会将整个序列的值聚合起来,在序列完成时发送一个最终值
Observable.sample: 从持续的序列中取得一定的样品
Observable.merge:将多个序列合并成一个,可以做OR来使用
Observable.timestamp: 能够得到每个发射值的发射时的时间
Observable.distinctUntilChanged(compare, selector): selector取出用来比较的key,compare用来比较两个key
Observable.takeWhile() 当参数为false时停止发射数据
 



您需要登录后才可以回帖 登录 | 立即注册

触屏版| 电脑版

技术支持 历史网 V2.0 © 2016-2017