import io.reactivex.Observable;
import io.reactivex.subjects.BehaviorSubject;

import java.util.concurrent.TimeUnit;

public class Random {
    public static void main(String[] args) throws InterruptedException {
        BehaviorSubject<Long> subject = BehaviorSubject.create();
        Observable.interval(1, TimeUnit.SECONDS).share().subscribe(num -> {
            subject.onNext(num);
        });
        subject.subscribe(num -> {
            System.out.println("sub1:" + num);
        });
        Thread.sleep(2000);
        subject.subscribe(num -> {
            System.out.println("sub2:" + num);
        });

        Thread.sleep(20000);
    }
}