RxJava share()

RxJavaExample.java

package com.antmobile.java;

import rx.Observable;
import rx.Subscriber;
import rx.schedulers.Schedulers;

public class FirstTempClass {

    public static void main(String[] args) {
        final Observable<Long> observable = Observable.create(new Observable.OnSubscribe<Long>() {
            public void call(Subscriber<? super Long> subscriber) {
                subscriber.onNext(System.nanoTime());
            }
        })
                .subscribeOn(Schedulers.io())
                .observeOn(Schedulers.io())
                .share();

        // First
        observable.subscribe(new Subscriber<Long>() {
            public void onCompleted() {
                System.out.println("");
            }

            public void onError(Throwable e) {
                System.out.println();
            }

            public void onNext(Long aLong) {
                System.out.println("first:= " + aLong);
            }
        });

        // Second
        observable.subscribe(new Subscriber<Long>() {
            public void onCompleted() {
                System.out.println();
            }

            public void onError(Throwable e) {
                System.out.println();
            }

            public void onNext(Long aLong) {
                System.out.println("second:= " + aLong);
            }
        });
        while (true) {

        }
    }
}