Examples for article "RxJava - Hello World"

MyClass.java

        Observable<String> observable = Observable
                .just("one", "two", "three");

        observable.subscribe(s -> System.out.println(s));

        Observable
                .just("one", "two", "three")
                .subscribe(s -> System.out.println(s));

        Observable
                .just("one", "two", "three")
                .map(s -> s.length())
                .subscribe(i -> System.out.println(i));

        Observable
                .just("one", "two", "three")
                .map(s -> s.length())
                .reduce(0, (a, b) -> a + b)
                .subscribe(i -> System.out.println(i));