This feels very close to just being able to use `r...

# rx

[locke]

This feels very close to just being able to use repeatWhen, except that will start the process over again from my original source, and I want to start it over using the new Observable<Message> I have. Something like a repeatWith?