rx-java
Scala streaming library differences (Reactive Streams/Iteratee/RxScala/Scalaz…)
PS: I wonder why Play Iteratees library has not been choosed by Martin Odersky for his course since Play is in the Typesafe stack. Does it mean Martin prefers RxScala over Play Iteratees? I’ll answer this. The decision of which streaming API’s to push/teach is not one that has been made just by Martin, but … Read more
Comparison of Java reactive frameworks [closed]
I’m working on RxJava and I did some evaluations on Akka-Streams and Reactor recently. As far as I can tell with all the libraries, they converge to a single concept called Reactive-Streams so you can go back and forth between the implementations. I believe RxJava is the most generic of all, has zero dependencies on … Read more
Get the latest value of an Observable and emit it immeditely
last() method will not be of any help here as it waits for the Observable to terminate to give you the last item emitted. Assuming that you do not have the control over the emitting observable you could simply create a BehaviorSubject and subscribe it to the observable that emits the data that you want … Read more