Hey everyone - not 100% sure if this belongs here ...
# rx
a
Hey everyone - not 100% sure if this belongs here since it's focused on rxjava rather than kotlins interaction with rxjava, so let me know if I should remove it and I will. Anyways, here's the question: I'm looking for a specific reactive interaction that I can't find. I have on observable that will emit items, say A -> B -> C -> D over 4 seconds. Then I have another observable that will emit 1 -> 2 -> 3 -> 4 -> 5 -> 6 -> 7 -> 8 over 4 seconds. I'm looking for a way to kind of 'chain' them together, so that after the first one emits A the second one will be free to emit 1, but will drop all other items until the first observable emits B, at which point in time it will free to emit the next item that it receives. Does anyone know of an operator that achieves this?