代码之家 › 专栏 › 技术社区 › rayman

对观测值使用concat后获得部分结果

reactive-programming rx-java java

rayman · 技术社区 · 9 年前

Observable<SomeResponseObject> method(){
    List<MyPojo> stream1...
    Observable<List<MyPojo>> stream2...

    return Observable.concat(Observable.from(stream1).toList(),stream2).map(users->
        createSomeResponseObject(users);
}

然而,当我调试SomeResponseObject时,我只看到流1 (流2的缺失结果)

通过单元测试执行:

        myClass.method().toBlocking().first();

stream2是这样创建的:

 return Observable.from(Arrays.asList(new MyPojo("user7"))).toList();

这两个列表的串联缺少了什么?

1 回复 | 直到 9 年前

akarnokd 9 年前

串联后有两个元素,但只等待第一个:

myClass.method().toBlocking().first();

我猜你想等两个:

myClass.method().toBlocking().last();

或者将两者同时打包:

myClass.method().toList().toBlocking().first(); // returns List<List<MyPojo>>

推荐文章

Mateusz Gebroski · 观察者设计模式——与现实世界的后端案例抗争

4 年前

Matej DrobniÄ · 如何在RxJava中正确转换多播观测值

8 年前

Viraj · 反应式编程如何实现相关结果

8 年前

val · 在Shiny中应用传单贴图边界过滤数据

8 年前

feerlay · RxJS-将可观察对象一分为二,等待第一个完成

8 年前

Binabiko · 角度表输入值

8 年前

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

8 年前

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

8 年前

en Peris · SpringBoot 2.0.0上的ServerRequest。发布

8 年前

iOSDev · 在react native中基于服务/动态地从json隐藏/显示标记

8 年前