stream1을 구독하는 .zip (stream1, stream2, BiFun)은 stream2가 stream1을 기반으로하는 경우 어떻게해야합니까?

Question

일부 복잡한 데이터가있는 Android의 firebase를 사용하고 있습니다. 참조를 저장해야하고 우편 번호 작업이나 RX 전체를 처리하는 방식에 문제가 있습니다.

특정 B에 대한 정보가있는 A object을 새로 만들고 B object에 A에 대한 정보가 업데이트되도록하고 싶습니다. 중포 기지 작업이 모두 성공적이었다 때 나는 로그 캣을 통과 할 때 Single<A>

val singleA = firebaseCall(A("ABC", bKey)) 

val singleB = singleA.flatMap{ a -> firebaseCall(B(aKey)) } 

return Single.zip(singleA, singleB, BiFunction { a, b -> a }) 

내가 SingleA 두 번에 가입 얻을 수 있음을 알 수 반환하고, 중포 기지로 두 번 밀어 것입니다. 나는 이것을 피하고 싶다!

그래서 B가 A에 종속적 인 경우 A와 B에서 zip 함수를 어떻게 사용할 수 있습니까? A가 두 번 수행되지 않았습니까?

Answer 1

당신은 진짜로 이것에 대한 zip이 필요하지 않습니다 당신이 할 수있는 간단한지도 a 다시 :

val singleA = firebaseCall(A("ABC", bKey)) 

return singleA.flatMap{ a -> firebaseCall(B(aKey)).map { a } }