Jet stream design is a collaborative effort by several engineers to define a standard minimum set of components that support (potentially) asynchronous backpressure event delivery (and synchronous shutdown). It mainly influenced RxJava in design along with Akka.
However, the resulting design was significantly different from RxJava, so RxJava 1.x would require a lot of binary incompatible changes to make it compatible. Instead, we have the RxJavaReactiveStreams bridge, and RxJava 2.0 is completely redefined by Reactive-Streams.
I have a four-part blog series on active threads in the light of RxJava.
source share