代码之家  ›  专栏  ›  技术社区  ›  thiagoh

RxJS可观察concat不工作

  •  11
  • thiagoh  · 技术社区  · 7 年前

    concat 呼叫我知道如果我替换 康卡特 通过 merge 代码工作正常,输出为 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

    1 回复  |  直到 7 年前
        1
  •  10
  •   Richard Matsen    7 年前

    我认为observer1需要 complete() ,则concat可以开始输出observer2。

    安眠药 CodePen