代码之家 › 专栏 › 技术社区 › Alex Kokorin

如何从GroupedObservable获取价值?

rx-java2 reactive-programming rx-java

Alex Kokorin · 技术社区 · 8 年前

我使用了groupBy迭代器,得到了GroupedObservable对象。现在我想把这个组简化为一个T对象。如何从GroupedObservable获取V?我只能看到getKey()操作符,而autocomplete对我没有帮助。

o.groupBy(player.getName())
 .flatMap(namePlayers -> {
       // How can I extract Observable<Player> from namePlayers

       // I want to write sth like this:
       .collect(Result::new, (result, player) -> result.mergeInfoFrom(player))
       .flatMapCompletable(result -> writeResultSomeWhere())
}

谢谢

2 回复 | 直到 8 年前

akarnokd 8 年前

A. GroupedObservable 是一个 Observable 所以你有通常的 map , filter , flatMap , collect 等。操作员可用。

Observable.range(1, 20)
.groupBy(v -> v % 2 == 0)
.flatMapMaybe(group -> {
    return group.reduce((a, b) -> a + b)
           .map(v -> "Group " + group.getKey() + " sum is " + v);
})
.subscribe(System.out::println);

djm.im Fan Cheung 6 年前

getObservable()
    .flatMap(Observable::from)
    .groupBy(player-> player.getName())
    .flatMap(player-> player.count()
    .map(player -> player)
    .subscribe(//** your logic for subscription **//);

使用GroupedObservable的一个简单示例。

推荐文章

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

8 年前

Myk Willis · 将具有指定泛型列表类型的Observable作为方法参数传递

8 年前

Mangat Rai Modi · 垂直。x反应式卡夫卡客户端:编写时链接不起作用?

8 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

8 年前

Jhon Fredy Trujillo Ortega · 如何在平面图中使用等待方法?

8 年前

casolorz · 可合成。清除导致OkHttp抛出java。lang.IllegalStateException:输入/退出不平衡

8 年前

O10 · 与observeOn组合时,RxJava启动时忽略运算符

8 年前

ddinchev · RxJava2并行执行一组completable并等待全部完成

8 年前

advice · RxJava-捕获使用者异常

8 年前

Daksh · 条件链单链和完全链

8 年前