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)) работает как надо, без ошибок.

Не уверен, почему это происходит.

0 ответов

Другие вопросы по тегам