Erste Teilergebnisse nach auf Observablen mit concat

Question

Ich habe folgende Ströme:

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

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

jedoch, wenn ich SomeResponseObject debuggen nur ich die Ergebnisse stream1 (fehlende Ergebnisse stream2) sehen

es die Ausführung über die Einheit-Testings:

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

stream2 erstellt auf diese Weise:

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

Was fehlt mir bei der Verkettung dieser beiden Listen?

Answer 1

Sie haben zwei Elemente nach der Verkettung, aber sie warten nur auf die erste:

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

Ich vermute, Sie beide warten wollen:

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

oder beide bekommen auf einmal gepackt zusammen:

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