Is there a way to loop a flatmap operation until s...

# rx

[locke]

Is there a way to loop a flatmap operation until some condition is met?

I have some Observable<Message>. When that Observable emits a message, I want to query that message for some state. Based on that state, I conditionally want to call foo(message): Observable<Message> and do that check again, repeating this process until I get the piece of state that I ultimately want to emit to my subscribe.