Example of RxJava being used with Java 8 lambdas

RxUsingJava8.java

import rx.Observable;

import java.util.ArrayList;
import java.util.List;

public class RxUsingJava8 {

    public static void main(String args[]) {

        /*
         * Example using single-value lambdas (Func1)
         */
        Observable.from(1, 2, 3, 4, 5)
                .filter((v) -> {
                    return v < 4;
                })
                .subscribe((value) -> {
                    System.out.println("Value: " + value);
                });

        /*
         * Example with 'reduce' that takes a lambda with 2 arguments (Func2)
         */
        Observable.from(1, 2, 3, 4, 5)
                .reduce((seed, value) -> {
                    // sum all values from the sequence
                    return seed + value;
                })
                .map((v) -> {
                    return "DecoratedValue: " + v;
                })
                .subscribe((value) -> {
                    System.out.println(value);
                });

    }
}

More information on RxJava can be found at https://github.com/Netflix/RxJava