reactivex

1热度

1回答

我使用的是Rx.Net，并且我有Observable可以发出时间序列点（double，timestamp）。每次新点到达时，我都想从最后30秒计算平均值。我想我需要一些不基于计数但是时间戳的重叠窗口/缓冲区。我发现this主题与SlidingWindow实现，但我无法弄清楚如何适应我的问题。编辑：感谢this我才知道，我可以使用扫描操作和缓冲区我的观点，所以这个basicly解决了这个问题。

1热度

1回答

如何将来自一个可观察值的值映射到具有可观察值的对上？

假设我有两个观测： Observable<MainInfo> mainInfoObs和 Observable<AdditionalInfo> additionalInfoObs(MainInfo mainInfo)功能。我想以某种方式将这些观测相结合，收到Pair<MainInfo, AdditionalInfo> 我不能只用拉链，因为additionalInfoObs取决于mainInfo。

2热度

1回答

为什么我得到NoClassDefFoundError的：组织/ reactivestreams /发行商

Stream.java import io.reactivex.*; public class Stream { public static void main(String args[]) { Observable.just("Howdy!").subscribe(System.out::println); } } 的build.gra

2热度

1回答

不同类型的Concat Observable

我有一个网络调用来验证和接收令牌，第二个使用此令牌请求数据。我想将它们合并为Single<Data>。为了做到这一点，我正在寻找concat，但这似乎只适用于同一类型的Observable。使用zip我可以仅返回第二个Observable的响应，但根据我的理解，它在并行中工作，而我需要等待第一个Observable并处理其响应，然后才能开始第二个响应。我应该为这种情况使用什么操作符？

0热度

2回答

如何映射RxSwift观察到的，结果

我有一个快速的问题：我有一个返回Observable<Result<String, RequestError>>网络请求，我们称之为requestToken 如果此请求成功，我想用String（令牌）做返回Observable<Result<NSDictionary, RequestError>>另一个请求，让我们把它requestData 当第二个请求回来，我想令牌合并到它的字典在我要地图结

4热度

1回答

使用ReactiveX for Java进行Http调用

我是ReactiveX for Java的新手，我使用下面的代码块来创建外部http调用，但它不是异步的。我们使用rxjava 1.2和Java 1.8 private ResponseEntity<String> callExternalUrl(String url, String json, HttpMethod method) { RestTemplate restTemplat

0热度

1回答

等待并累计值，直到其他可观察到的火灾

我有两个可观察值，而我只需要每个值。如果observable2先推入一个值，我想等待并保持收到的值，直到observable1推入一个值并推送保持的值。基本上与skipUntil相同的行为，不同之处在于我不想放弃该值。我想我可以通过对可观察数据进行连接来做到这一点，但我希望将它们分开。 observable1 .take(1) .subscribe(doSomething)

2热度

1回答

RxSwift：如何通过多个视图模型

我有一个按钮集合观察室通过一个控制的事件，我想透过细胞的视图模型通过水龙头控制事件（button.rx.rap），通过视图控制器的视图模式，到集合视图控制器本身（如我需要出示上轻敲事件的视图控制器）。这怎么能在这样的Rx（最好不使用对象）来实现？

0热度

1回答

防止多个API调用

如何在不保存状态（例如，将状态保存为“isLoading”属性）的情况下防止多个长时间api调用（例如用户多次点击按钮）。

2热度

3回答

RxJava2：替代rx.Observable方法首先（谓语）

我想用RxJava但不能想出替代的方法 public final Observable<T> first(Func1<? super T,java.lang.Boolean> predicate) 在RxJava2 。我想要做的是以下几点： return io.reactivex.Observable .concat(source1, source2, source3, sourc