reactivex

0热度

1回答

场景：我有一个customerID字符串，用于查询多个不同的后端系统：日历，帮助台，ERP，CRM等。我想编译一个报告。所以我有大约（psydocode）： Result myResult = new Result(); Observable<Cal> cal = Calbackend.get(customerid); cal.subscribe(calentry -> myResult.a

0热度

2回答

使用JavaRx/rx-mongodb下载grails中的文件

我正尝试在Grails 3.2.1中下载文件。我有一个名为“文件”的org.bson.types.Binary类型保存在mongo-db中。存储的文件的大小以kb为单位，因此不需要GridFS。我可以使用org.bson.types.Binary提供的getData（）辅助函数来访问byte []。使用标准蒙戈-DB驱动程序，我可以用下面的实现： - class DownloadControll

0热度

1回答

reactivex：在一种窗口函数中采取take和take的组合

我是ReactiveX的一名相对新手，已经学习了Rx.Observable.take和Rx.Observable.takeLast分别从一个序列的开头和结尾开始，并从Rx.Observable.windowWithCount获取潜在的重叠窗口一个原始的可观察的。为了好玩，我想完全使用反应式运算符和换能器编写FFT算法。一些算法很直观，但有些很难用流模型。具体来说，一个rfft作用于一个序列的开始和

0热度

2回答

RxJS/ReactiveX正确的模块通信

我很新的反应编程，但已经恋爱了。然而，我的大脑仍然很难转向它。我试图按照“避免使用主题”和“避免不纯的功能”以及“避免命令式代码”的所有建议。我发现很难实现的是简单的交叉模块通信，其中一个模块可以注册“action”/ observable，另一个可以订阅并对其作出反应。一条简单的消息总线可能会工作，但这会强制使用主题和我试图避免的命令式代码风格。因此，这里是一个简单的出发点，我用打： //

0热度

1回答

连接到一个可观察到的许多观察者接收事件一次一个

这是我创造我观察到： Observable.fromCallable(new EventObtainer()).flatMap(Observable::from).subscribeOn(Schedulers.io()).repeat(); 而在这之后，通过HTTP请求我想要添加不同的观察者。问题是，如果我有不止一个观察者，我无法预测哪个观察者将获得发射物品。为什么不可观察到的东西会向每个订阅

1热度

1回答

链接依赖观测值

我需要创建依赖API调用，其中第二个需要第一个返回的值。其中，全成调用返回更新Report模型（用ID）后，在那之后我需要调用API来创建报告步骤，其中需要report.ID我想到的第一件事就是用flatMap ApiManager.shared .createReport(report: report) .flatMap { (report) -> Observable<Re

4热度

2回答

使用RxSwift观察UITextField.editing

我想观察属性UITextfield.editing。我正在使用此代码： self.money.rx_observe(Bool.self, "editing").subscribeNext { (value) in print("") }.addDisposableTo(disposeBag) 但是在运行过程中，它只执行一次。如何解决此问题，请

2热度

3回答

选择器可观察 - RxSwift

我试图从ReactiveCocoa 2.5到RxSwift我有一个误解。在ReactiveCocoa中，当我想要观察方法的调用时，我使用rac_signalForSelector。有什么办法可以用RxSwift来实现这个逻辑吗？我写了一个小例子，我想在test方法调用时处置订阅。但是在订阅块中，我仍然可以看到一个next(6)事件。我究竟做错了什么？ let subject = PublishS

0热度

1回答

RxSwift throttle（）获取第一个元素

我正在寻找一种方式，throttle()运算符在给定的时间间隔内放弃Observable中的第一个元素，而不是最后一个元素。在RxSwift - Debounce/Throttle "inverse"中已经提出了类似的问题（并回答了），但是我想避免的答案中存在一些不完善之处。也就是说，在理想的情况下，获得在Observable中发射的第一个元素，并且在时间间隔期间任何未来的元素都被忽略。但是，与

0热度

1回答

RxSwift PublishSubject被设置

我绑定按钮按压以PublishSubject在路由器中，像这样： hambugerButton .rx_tap .bindTo(router.openMenu) .addDisposableTo(disposeBag) 以我路由器： let openMenu = PublishSubject<Void>() //... openMenu .map {