RxJS "объединить" не удается с обещаниями
Я пытаюсь объединить результат API-вызовов для приложения React через merge
а также from
наблюдаемые операторы, подобные этому:
import { from, merge } from 'rxjs';
import { map, scan } from 'rxjs/operators';
merge(
from(
new Promise(function(resolve, reject) {
setTimeout(resolve, 100, 'foo');
}),
//... all actions/promises go here
),
).subscribe(actions.next);
я получил Uncaught TypeError: Cannot read property 'length' of undefined
ошибка для следующего кода:
if (!this.isStopped) {
var observers = this.observers;
var len = observers.length;
var copy = observers.slice();
for (var i = 0; i < len; i++) {
copy[i].next(value);
}
}
Это часть пакета RxJS.
Если я сделаю .subscribe(observer => action.next(observer))
работает как надо, без ошибок.
Не уверен, почему это происходит.