MultipleSubscribersWithoutSubjectsExample.java

        /*
         * Step 1: Create an observable that emits an integer
         * from 1 to 5. Each item is squared by itself before it is
         * emitted.
         *  */
        Observable<Integer> observable = Observable.range(1, 5)
                .subscribeOn(Schedulers.io())
                .map(integer -> {
                    System.out.println(String.format("Squaring %d with itself", integer));
                    return integer * integer;
                });

        /*
         * Step 2: We are subscribing two subscribers to the Observable.
         *  */
        observable.subscribe(s -> System.out.println("subscriber one: " + s));
        observable.subscribe(s -> System.out.println("subscriber two: " + s));