[nocneszczury]

#programowanie #rx #java, taguję też #csharp bo pewnie operatory do rx są takie same.
Mam 2 strumienie (A,B) , chciałbym stworzyć nowy (C) który działa w taki sposób w taki sposób:
1) Subskrybuję się do C
2) Strumień A emituje element, jeśli jest ok to (3)
3) Strumień B emituje element, jeśli jest ok to (4)
4) Strumień C emituje parę elementów a punktów 2 i 3

[b.....7]

@nocneszczury: 2 i 3 filter 4 zip

[nocneszczury]

@boo007 zip wywoła A i B jednocześnie, chciałbym żeby B było wysłane w momencie, gdy A wyemituje element

[b.....7]

@nocneszczury: nie wiem, kombinował bym z pull-backpressure i onBackpressureBlock

[rex1313]

Cos takiego powinno zadziałać jeśli dobrze zrozumiałem.
a.flatMap(a->b.flatMap(b->wartosci z a i z b sa tu widoczne, wiec mozesz wykonac c).subscribe(c->wynik c)

[nocneszczury]

@rex1313: flatMap wywoła A i B w tym przypadku jednoczesnie?

[rex1313]

@rex1313: Nie, nie wywoła jednocześnie, b "poczeka" na a, c poczeka na b. Jeśli chcesz jednocześnie to prawdopodobnie to czego szukasz to combineLatest(observable1, observable2)
Tutaj diagram:
http://reactivex.io/documentation/operators/combinelatest.html