reactivex

    2热度

    1回答

    从this post继,我有以下 Observable.combineLatest( this.translate.get("key1"), this.translate.get(""), this.translate.get("key3"), this.translate.get("key4") ) .subscribe(([re

    2热度

    1回答

    基于我想构建forkJoin()方法的函数的参数。 例如: 如果参数1是空=>不把一个http请求为它 forkJoin() 内如果参数2为空=>不把一个http请求它 的forkJoin()内 代码: getAllByIds(parameter1: any, parameter2: any) { let itemList = new Array(); return Obs

    2热度

    1回答

    我有一个事件回调方法 public void onSomethingHappened(Information info) { 其通过一些常规事件发行者调用。 现在我希望将其包含到ReactiveX observable中。 如何做到这一点? UPDATE 我发现PublishSubject<T>类,并用这种以下列方式从Android API包LocationListener: public c

    0热度

    1回答

    如果我的模型的propery发生更改,我需要每次调用JQuery函数。 person = {firstName:firstName, lastName:lastName} 作为一个例子。如果我改变的人对象的的firstName财产,我每次需要触发的功能。其实我需要一个像这个对象的属性订阅的东西。 这怎么可能? 在此先感谢。

    7热度

    3回答

    在反应式编程中涉猎很多时,我经常会遇到两个流互相依赖的情况。什么是解决这些案件的惯用方法? 一个简单的例子:有按钮A和B,都显示一个值。点击A必须使B的值增加B.点击B必须将B的值设置为A. 我可以想出第一个解决方案(例如F#,但欢迎任何语言的答案): let solution1 buttonA buttonB = let mutable lastA = 0 let mutab

    0热度

    1回答

    我使用RxSwift绑定视图模型和视图,和我有大约10名司机,在我的视图模型暴露属性: let title: Driver<String> let description: Driver<String> let price: Driver<String> ... 从传入的模型序列中驱动这些观测量的最佳方法是什么?是否最好观察每个驾驶员的来电?这是一种奇怪/无效的做事方式吗? self.t

    1热度

    2回答

    是否存在与Android的状态变化(如方向改变)或异步平台事件(如推送通知事件)等打交道时处理RxJava订阅优雅的方式? 我一直在使用EventBus来处理类似这样的事情,并且如果可能的话(如果可能的话)会完全转移到RxJava上(不需要EventBus),但不知何故EventBus架构看起来好多了(只是注册并根据需要取消注册)来处理这些场景,特别是在处理Android平台事件时。 单独RxJa

    0热度

    1回答

    我有一个应用程序,显示当前的天气。数据通过Alamofire从forecast.io下载。结果形成一个预测表。我使用简单的tableviewdelegate和tableviewDatasource,一切正常。但是现在我想用rxswift和rxcocoa来学习一些被动的。一些google搜索,并从raywanderlich教程后:我改变了我的代码: var week = Variable<[Dail

    0热度

    2回答

    在Python中使用ReactiveX,我该如何总结一个Observable流? 我有一个{“user”:“...”,“date”:...}字典流。我想创建一个函数,我可以应用这个函数,为每个用户累积最新日期的字典,然后在流结束时发出累积的观察值(这就像max,但必须查看用户字段,并且会发出多个值)。 示例 - 输入流: { "user": "a", "date": "2017-02-14" }

    0热度

    2回答

    我需要编写随机发生器作为可观察。观察者会在很长一段时间内对下一个值做些什么。所以我希望只在观察者需要时才发出新的随机数,或者可能的话还有两个额外的数字,但不能再多。 怎么办? P.S.如果重要,我使用Java。