Наблюдаемые кеши испускают предметы или нет?

Question

Есть ли наблюдаемые кеши испускаемые предметы? У меня есть два испытания, которые приводят меня к разным выводам:

От испытываемого # 1 я делаю вывод о том, что он делает:

Test # 1:

Observable<Long> clock = Observable 
    .interval(1000, TimeUnit.MILLISECONDS) 
    .take(10) 
    .map(i -> i++); 

//subscribefor the first time 
clock.subscribe(i -> System.out.println("a: " + i)); 

//subscribe with 2.5 seconds delay 
Executors.newScheduledThreadPool(1).schedule(
    () -> clock.subscribe(i -> System.out.println(" b: " + i)), 
    2500, 
    TimeUnit.MILLISECONDS 
); 

Выход №1:

a: 0 
a: 1 
a: 2 
    b: 0 
a: 3 
    b: 1 

Но второй тест показывает, что мы получаем разные значения для двух наблюдателей:

Test # 2:

Observable<Integer> observable = Observable 
       .range(1, 1000000) 
       .sample(7, TimeUnit.MILLISECONDS); 
observable.subscribe(i -> System.out.println("Subscriber #1:" + i)); 
observable.subscribe(i -> System.out.println("Subscriber #2:" + i)); 

Выход # 2:

Subscriber #1:72745 
Subscriber #1:196390 
Subscriber #1:678171 
Subscriber #2:336533 
Subscriber #2:735521 

Answer 1

Существует два вида наблюдений: горячие и холодные. Холодные наблюдаемые, как правило, генерируют одну и ту же последовательность своим Наблюдателям, если у вас нет внешних эффектов, таких как связанное с таймером действие, связанное с ним.

В первом примере вы получаете одну и ту же последовательность дважды, потому что нет внешних эффектов, кроме таймерных тиков, которые вы получаете по одному. Во втором примере вы выбираете быстрый источник, а выборка со временем имеет не детерминированный эффект: каждая наносекунда считается так, что даже малейшая неточность приводит к различному значению.