jwkidd3 · January 18, 2017 22:10
diff --git a/cold b/cold
 Observable<Long> cold = Observable.interval(200, TimeUnit.MILLISECONDS);

 cold.subscribe(i -> System.out.println("First: " + i));
 Thread.sleep(500);
 cold.subscribe(i -> System.out.println("Second: " + i));
	Observable<Long> cold = Observable.interval(200, TimeUnit.MILLISECONDS);

	cold.subscribe(i -> System.out.println("First: " + i));
	Thread.sleep(500);
	cold.subscribe(i -> System.out.println("Second: " + i));