我知道observe()
除非其他消费者已经在工作,否则不会消耗价值或触发消费,而fork()
会自行触发消费。但是,假设我有一个 stream source_stream
。如果我做
var observer_1 = source_stream .observe ();
var observer_2 = source_stream .observe ();
source_stream .each ( console .log );
然后保证两个观察者收到相同的值。但如果我这样做
var forker_1 = source_stream .fork ();
var forker_2 = source_stream .fork ();
这两个分叉器会有什么价值?它们是相同的、不同的还是其他?什么规则决定了哪些值被推入其中?谢谢!