RxJava：如何在不破坏链条的情况下有条件地将 *** 作符应用于Observable

概述我在RxJavaobservable上有一系列运算符.我希望能够根据布尔值应用两个运算符中的一个,而不会“破坏链”.我对Rx(Java)比较陌生,我觉得这可能比我目前引入临时变量的方法更具惯用性和可读性.这是一个具体的例子,如果批量大小字段为非空,则从observable缓冲项,否则使用toList()发

我在RxJava observable上有一系列运算符.我希望能够根据布尔值应用两个运算符中的一个,而不会“破坏链”.

我对Rx(Java)比较陌生,我觉得这可能比我目前引入临时变量的方法更具惯用性和可读性.

这是一个具体的例子,如果批量大小字段为非空,则从observable缓冲项,否则使用toList()发出单批无限大小：

Observable<Item> source = Observable.from(newItems);Observable<List<Item>> batchedSource = batchSize == null ?                source.toList() :                source.buffer(batchSize);return batchedSource.flatMap(...).map(...)

这样的事情可能吗？ (伪lambda因为Java)：

Observable.from(newItems)    .applyIf(batchSize == null,             { o.toList() },             { o.buffer(batchSize) })    .flatMap(...).map(...)

解决方法:

您可以使用compose(Func1)按顺序保留但执行自定义行为

source.compose(o -> condition ? o.map(v -> v + 1) : o.map(v -> v * v)).filter(...).subscribe(...)

总结

以上是内存溢出为你收集整理的RxJava：如何在不破坏链条的情况下有条件地将 *** 作符应用于Observable全部内容，希望文章能够帮你解决RxJava：如何在不破坏链条的情况下有条件地将 *** 作符应用于Observable所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。