Observable 是否缓存已发出的项目？

Question

Observable 是否缓存发射的项目？我有两个测试导致我得出不同的结论：

从测试 #1 我得出的结论是：

测试 #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

但是第二个测试表明我们得到了两个观察者的不同值：

测试 #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

存在两种 Observable：热和冷。 Cold observables 倾向于为其 Observers 生成相同的序列，除非你有外部效果，例如基于计时器的操作，与之相关联。

在第一个示例中，您会获得两次相同的序列，因为除了计时器滴答声之外没有任何外部效果，您会一次次获得。在第二个示例中，您对快速源进行采样，并且随时间采样具有不确定性：每一纳秒都很重要，因此即使是最轻微的不精确也会导致报告的值不同。