Implicit conversion to Scala Future for Observable

ReactiveX / RxScala

RxScala – Reactive Extensions for Scala – a library for composing asynchronous and event-based programs using observable sequences

Apache License 2.0

888 stars 110 forks source link

Closed greatbalin closed 6 years ago

greatbalin commented 6 years ago

Main idea of this change it to make it possible to simply move from Observable to Future when needed.

samuelgruetter commented 6 years ago

Why do you force users to specify a timeout? What if they want to wait indefinitely? I think the issue of converting from Observable to Future and the issue of timeouts are orthogonal and should not be mixed up.
It seems you are kind of reinventing the wheel, couldn't you use something like obs.toBuffer.toBlocking.toFuture?

greatbalin commented 6 years ago

Yes! you are right!

By some reason I totally forgot about toBuffer .