mergeMap выдает ошибку «недопустимый объект, где ожидался поток» в rxjs6

После переноса rxjs с v5 на v6 возникает ошибка при использовании mergeMap:

of('foobar').pipe(
  mergeMap(() => of('baz'))
).subscribe(console.log);  

Ошибка:

core.js:1598 ERROR TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
    at Object.push../node_modules/rxjs/internal/util/subscribeTo.js.exports.subscribeTo (subscribeTo.js:42)
    at Object.subscribeToResult (subscribeToResult.js:7)
    at MergeMapSubscriber.push../node_modules/rxjs/internal/operators/mergeMap.js.MergeMapSubscriber._innerSub (mergeMap.js:132)
    at MergeMapSubscriber.push../node_modules/rxjs/internal/operators/mergeMap.js.MergeMapSubscriber._tryNext (mergeMap.js:129)
    at MergeMapSubscriber.push../node_modules/rxjs/internal/operators/mergeMap.js.MergeMapSubscriber._next (mergeMap.js:112)
    at MergeMapSubscriber.push../node_modules/rxjs/internal/Subscriber.js.Subscriber.next (Subscriber.js:103)
    at Observable._subscribe (scalar.js:5)
    at Observable.push../node_modules/rxjs/_esm5/internal/Observable.js.Observable._trySubscribe (Observable.js:176)
    at Observable.push../node_modules/rxjs/_esm5/internal/Observable.js.Observable.subscribe (Observable.js:161)
    at MergeMapOperator.push../node_modules/rxjs/internal/operators/mergeMap.js.MergeMapOperator.call (mergeMap.js:87)

of('baz') это поток, верно? Так почему я получаю эту ошибку?


person Upvote    schedule 01.06.2018    source источник
comment
Вы правильно сделали импорт? импорт {из} из 'rxjs'; импортировать {mergeMap} из 'rxjs/operators';   -  person siva636    schedule 01.06.2018
comment
@ siva636 ohhh myyy ... это был rxjs/internal/operators .. Я переключил его на rxjs/operators, и теперь он работает :D   -  person Upvote    schedule 01.06.2018


Ответы (1)


Убедитесь, что вы правильно импортировали операторы из

rxjs/operators

и не

rxjs/internal/operators
person Upvote    schedule 01.06.2018
comment
Большое спасибо, что сэкономили мне время! - person Sebastien DErrico; 11.11.2020