Гарантируемая заметная подписка заканчивается до перехода к следующему коду - PullRequest
Новая
       7

Гарантируемая заметная подписка заканчивается до перехода к следующему коду

0 голосов
/ 26 июня 2018

Я делаю немного каскадного удаления с несколькими сервисными вызовами. Некоторые из более поздних подписок полагаются на предыдущие подписки для завершения. Как я могу гарантировать завершение подписки перед переходом на следующий код? 

// Need to make sure this code completes
data.forEach(element => {
    this.myService.delete(element.id).subscribe();
});

// Before running this code
this.myService.getAll().subscribe(res => {
        res.data.forEach(element => {
            this.myService.delete(element.id).subscribe();
        });
    }
);

1 Ответ

0 голосов
/ 26 июня 2018

A Subscription имеет единственное назначение: утилизация, но у вас есть варианты:

  • Если вы хотите подписываться на наблюдаемые один за другим, вы можете использовать concat.

  • Если вы хотите подписаться на несколько наблюдаемых одновременно и объединить последние значения каждого, вы можете использовать forkJoin.

  • Если вы хотите использовать полученное значение наблюдаемой в другой наблюдаемой, вы можете использовать flatMap. 

import { forkJoin, interval, concat, of } from "rxjs";
import { first, flatMap } from "rxjs/operators";

var combinedIntervals =
    forkJoin(
        interval(1000).pipe(first()),
        interval(2500).pipe(first())
    ).pipe(
        flatMap(([a, b]) => of(`${a} and ${b}`))
    );

concat(
    combinedIntervals,
    of("after both intervals")
)
.subscribe(
    console.log.bind(console)
);


// 0 and 0
// after both intervals

В вашем конкретном случае вы бы выбрали операции удаления в качестве наблюдаемых, а затем разошлись бы по ним. 

var data = [];

var obsBatch1 = data.map(element => myService.delete(element.id));
var obsBatch2 =
    forkJoin(
        obsBatch1,
        elements => elements.map(
            element => myService.delete(element.id)
        )
    );

obsBatch2.subscribe();

Это синтаксис rxjs@6. Я оставляю rxjs@5 как упражнение.

...