RxJS 可观察到的连接不起作用

Question

concat 调用发生了什么？我知道如果我用 merge 替换 concat 代码工作正常并且输出是 foo bar qux quux。我已经阅读了有关热和冷可观察量的信息，并且我知道如果在订阅之前生成值，则可能会发生热可观察量，但我的可观察量是 cold，所以我想情况并非如此。

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

RxJS 可观察到的连接不起作用

RxJS observable concat not working

javascript

observable

rxjs

reactivex