javascript - RxJS observable concat not working - Stack Overflow

admin管理员组

文章数量:1344939

What is going on with the concat call? I know that if I replace concat by merge the code works correctly and the output is foo bar qux quux. I've read about Hot and Cold observables, and I know that for hot observables that might happen if the values are generated before the subscription, but my observables down there are cold, so I guess that's not the case.

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

What is going on with the concat call? I know that if I replace concat by merge the code works correctly and the output is foo bar qux quux. I've read about Hot and Cold observables, and I know that for hot observables that might happen if the values are generated before the subscription, but my observables down there are cold, so I guess that's not the case.

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

• javascript
• rxjs
• observable
• reactivex

Share Follow asked Oct 11, 2017 at 2:31 thiagohthiagoh 7,41888 gold badges5454 silver badges7878 bronze badges

Add a ment  | 

1 Answer 1

Sorted by: Reset to default 11

I believe observer1 needs to plete(), then concat can start outputting observer2.

Ammended CodePen

本文标签： javascriptRxJS observable concat not workingStack Overflow