Could you be more specific?
If you want to create an
Observable from a list of objects then you can call
And then you could call
mapEval (if your mongo/cassandra connector returns
Task ) or
mapEvalF (if it's something else), or
flatMap (if it's
In case you're still wondering about it, nothing built-in comes to my mind.
scan can work well.
Other option is keeping the last value in a shared variable (
volatile ) or modifying
OnErrorRecoverWithObservable to keep track of the latest value.
I feel like the last option should work best if you want to restart
Observable in case of an error and
Observable[Either[Throwable, A]] is better if you want to have an option to handle the error without restart.
timeoutOnSlowUpstreamdo what i want ?