RxJS可观察的concat无法正常工作

Question

这是怎么回事用concat电话吗？我知道,如果我取代concat由merge代码正常和输出foo bar qux quux.我已经阅读过Hot和Cold observables,我知道如果在订阅之前生成值可能会发生热观察,但是我的可观察结果很冷,所以我想情况并非如此.

const Rx = require('rxjs');

const observable1 = Rx.Observable.create((observer) => {
  observer.next('foo');
  observer.next('bar');
  return observer;
});
const observable2 = Rx.Observable.create((observer) => {
  observer.next('qux');
  observer.next('quux');
  return observer;
});
const result1 = observable1.concat(observable2);
result1.subscribe((x) => console.log(x));

// outputs
foo
bar

https://codepen.io/thiagoh/pen/WZyrRL

Answer 1

我相信observer1需要complete(),然后concat可以开始输出observer2.

推荐使用CodePen