What you’ve written is the kind of thing you’d wan...
# rx
a
What you’ve written is the kind of thing you’d want to return from a FlatMap. If you can generate an infinite stream and then flatmap your getData… function into it, and then apply your takeUntil method, you should be good