reactivex

1热度

2回答

rxjs：使用流指向已经完成上游的observable的两次

我在使用后从热的observable获取值时遇到了问题。 const partialState$ = Rx.Observable.of(1) .publish().refCount(); const downstreamState$ = partialState$.map(v => ([v+1, v+2])); const finalState$ = downstre

javascript stream rxjs reactive-programming reactivex 2016-12-07

---

1热度

1回答

RxPy读取csv文件和进程行

我想使用RxPy打开一个（csv）文件并逐行处理文件。我正是我设想有以下步骤 提供一个文件名到流 打开由线 文件 读取文件中的行删除与注释（例如＃开头的行.. 。） 申请CSV阅读 筛选记录满足某种条件 到目前为止，我有： def to_file(filename): f = open(filename) return Observable.using( lambda: Anonymo

python reactivex 2016-12-29

---

4热度

1回答

链条观察对象

我有一个对象集合，称它们为obj。他们有一个act()方法。 act()方法将最终导致在o上可见的event()调用onComplete。 什么是链接这些的好方法？ 也就是说，拨打o.act()，等待o.event().onComplete，然后呼叫下一个o2.act()，等在集合o不定。 所以它的签名是像这样： public class Item { final protected P

java rx-java reactivex 2017-01-01

---

0热度

2回答

如何创建两个排序的observables之间的差异observable？

假设我有两个有序的双打的可观察物。我想把它们之间的区别看作是可观察的。例如： 1 2 4 left: ──o───────o───────────o────/ 1 3 4 5 right: ──o────o──o───o───/ l2 r3 r5 output: ──────────o───────────o────o─/ 当务之急实现很

rx-java reactive-programming observable reactivex rx-scala 2017-01-03

---

1热度

1回答

RxSwift：防止多个网络请求

我目前在使用RxSwift Observables时执行多个网络请求时会出现问题。我明白，如果一个人创建了一个冷观察者，并且它有多个观察者，那么观察者将在每次订阅时执行它的块。 我试图创建一次执行网络请求的共享订阅observable，并将多个订户通知结果。以下是我所尝试的。事件 的 序列与一个UIButton 的点击事件创建视图模型创建serviceStatus观察为上视图模型公共财产。这个Ob

ios rx-swift reactivex 2017-01-16

---

8热度

1回答

RxJava 2.0 - 如何将观察者转换为发布者

如何将观察者转换为RxJava版本2中的发布者？ 在第一个版本中，我们有https://github.com/ReactiveX/RxJavaReactiveStreams项目，正是我所需要的。 但是我怎样才能在RxJava 2中做到这一点？

java reactive-programming reactivex reactive-streams rx-java2 2016-11-29

---

1热度

2回答

延迟条件

有一个代码： someObservable.Select(x => getY(x)); Y getY(X x) { if (x.Value == X.ABC) return new Y(1); else return new Y(2); } 在某些条件下，我需要加倍的一段时间后检查x.Value。 最简单和坏的解决方案是使用了Thread.Sle

.net system.reactive reactivex 2016-12-03

---

0热度

1回答

rxswift：如何获得Observable <Any>导致Observable <[Category]>的组合？

我的方法有些疑问。我有两个类型观测值： //I can fetch from the server the houses and save them in the database func houses() -> Observable<[House]> //Given a houseId, I can fetch it's details and save them in the data

swift reactive-programming rx-swift reactivex reactive 2016-12-06

---

1热度

1回答

ReactiveCommand臭虫ReactiveUI

我使用Net40 ReactiveUI与WinForms和正常工作时，我刚在： public class VMUpdates : ReactiveObject { ... public ReactiveCommand<object> btnClick { get; private set; } public VMUpdates(frmMain frmMain)

c# viewmodel reactiveui reactivex 2016-12-12

---

0热度

2回答

发布/消耗：等待上订阅，消息过滤器和具有处置

使用Rx.Net 3 随着使用Quartz.Net调度的我建立一个工作流程管理器链作业（成品作业使用Quartz Joblistener）嵌入式Web服务器。 应用程序实例化Subject（单例）的实例。 Web服务获取数据并启动工作流，注入唯一的ID。这个唯一的ID通过工作流传播。 Joblistener委托检测特定作业的结束，并在注入的Subject实例上调用OnNext，并使用包含唯一标识和

c# .net system.reactive reactivex 2016-12-24

---