rxjs добавить / удалить из наблюдаемого массива

Question

В следующем коде есть ошибки компиляции, говорящие о том, что возврат concat нельзя присвоить Observable. Так как же мне добиться следующего?

let o1$: Observable<Object[]> = this.apiService.get();
let o2$: Observable<Object> = of({ a: "b" });
let o1$ = concat(o1$, o2$);

Плюс, как я могу удалить Object из o1$?

Answer 1

Наблюдаемые не работают таким образом. Они не являются синхронными, поэтому такие операции, как удаление или передача в / из наблюдаемой, не работают, поскольку у вас нет полного набора данных, доступного для вас. Это более / менее поток.

Вместо этого вы фильтруете, пропускаете, берете n или любую другую операцию фильтрации потока:

o1$.filter(o => isGood(o));

Или объединение, forkJoin, Объединение последних и т. Д., Несколько потоков:

merge(a$, b$)

Операторы по категориям

Надеюсь, это поможет!