Reactive Extensions for Java

Question

Is there any equivalent of Reactive Extensions (.NET) for Java?

About Rx (Reactive Extensions)

Rx is a library for composing asynchronous and event-based programs using observable collections.

I am aware of rule engines such as Drools from JBOSS, but is there some other way that is closer to the Microsoft .NET approach?

Answer 1

RxJava (RX ported by Netflix) is available and stable here: https://github.com/ReactiveX/RxJava.

It even works with Java 8's lambda syntax pretty well! You can do stuff like that:

Observable
  .from(Arrays.asList(1, 2, 3, 4, 5))
  .filter(val -> val % 2 == 0)
  .map(val -> val * val)
  .scan(0, (prev, curr) -> prev + curr)
  .subscribe(System.out::println)

Pretty cool a?