rxjava version of FIZZBUZZ

rxFIZZBUZZ

import rx.Observable;
import rx.observables.ConnectableObservable;

public class RxFizzBuzz {
    public static void main(String[] args) {
        final ConnectableObservable<Integer> range = Observable.range(1, 100).publish();

        final Observable<String> out = Observable.merge(
                range.filter((n) -> n % 15 == 0).map((n) -> "FIZZBUZZ"),
                range.filter((n) -> n % 15 != 0 && n % 3 == 0).map((n) -> "FIZZ"),
                range.filter((n) -> n % 15 != 0 && n % 5 == 0).map((n) -> "BUZZ"),
                range.filter((n) -> n %3 != 0 && n % 5 != 0).map((n) -> Integer.toString(n)));

        out.subscribe((str) -> System.out.println(str));
        range.connect();
    }
}