import io.reactivex.rxjava3.core.Observable;

import io.reactivex.rxjava3.observables.ConnectableObservable;

import java.util.concurrent.TimeUnit;

public class Ch2_19 {

public static void main(String[] args) {

ConnectableObservable<Long> seconds =

Observable.interval(1, TimeUnit.SECONDS).publish();

//observer 1

seconds.subscribe(l -> System.out.println("Observer 1: " + l));

seconds.connect();

//sleep 3 seconds

sleep(3000);

//observer 2

seconds.subscribe(l -> System.out.println("Observer 2: " + l));

//sleep 3 seconds

sleep(3000);

}

private static void sleep(int millis) {

try {

Thread.sleep(millis);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}