代码之家 › 专栏 › 技术社区 › Picci

组合2个观察值,使一个仅在第二个发射时发射下一个值

reactive reactive-programming observable rxjs

Picci · 技术社区 · 8 年前

我有一个可观察的 Obs1 已使用该方法创建 from 从一组对象开始。

假设数组有10个对象,这意味着发射10次,然后终止。

对于发射的每个对象 Obs1 我想执行一个函数,返回一个可观察的。因此,函数返回的可观测值与数组元素的数量相同,让我们调用它们 Obs2-1 Obs2-2 ... Obs2-10 . 这样的观察值只发出一个值,然后完成。

我想以某种方式链接 Obs1 到一系列观察值 Obs2-1 ... Obs2-10 因此 Obs1 发射its (n+1)-第个值 什么时候 Obs2- n 发射。

一个真实的例子可以使这件事更清楚。假设我有一个字符串数组。每个字符串都是文件名。我有一个函数 r-w-files(files: Array<string>) 它读取列表中的每个文件并将其写入另一个目录。

我想对大量文件执行这种读写逻辑,因此,为了避免同时打开太多文件,我想将大的初始列表划分为较小的块,然后用函数顺序处理它们 r-w文件(文件:数组<字符串>) .

我想象的是有一种特定形式的块缓冲区

有没有办法用可观察算子实现这种逻辑?

1 回复 | 直到 8 年前

ZahiC 8 年前

要按顺序切换观察值,可以使用 连接图 :

Rx.Observable.from(['value 1', 'value 2', 'value 3'])
  .concatMap(value => createNewObservable(value))
  .subscribe()

连接图 等待之前创建的可观察对象完成后再切换到下一个。

推荐文章

Mateusz Gebroski · 观察者设计模式——与现实世界的后端案例抗争

3 年前

Matej DrobniÄ · 如何在RxJava中正确转换多播观测值

7 年前

Viraj · 反应式编程如何实现相关结果

7 年前

val · 在Shiny中应用传单贴图边界过滤数据

7 年前

feerlay · RxJS-将可观察对象一分为二,等待第一个完成

7 年前

Binabiko · 角度表输入值

7 年前

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

7 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

7 年前

en Peris · SpringBoot 2.0.0上的ServerRequest。发布

7 年前

iOSDev · 在react native中基于服务/动态地从json隐藏/显示标记

7 年前