RXJS прослушать первую подписку - PullRequest
Новая
       6

RXJS прослушать первую подписку

0 голосов
/ 01 марта 2019

У меня есть функция, которая переносит наблюдаемое с обработкой ошибок, но для этого мне нужно запустить некоторый код, как только его внутренняя наблюдаемая подписана.

Мне также нужно, чтобы отмена более высокого значения Observable отменяла внутреннееодин, как это делает HTTP-вызов.

Context 

slideshow: string[] = [];
currentIndex = 0;
private is = {
    loading: new BehaviorSubject(false),
}

private loadImage(src: string): Observable;

private loadNextImage(index = this.currentIndex, preload = false): Observable<number> {
    const nextIndex = (index + 1) % this.slideshow.length;
        if (this.currentIndex == nextIndex) {
        if (!preload) {
            this.is.loading.next(false);
        }
        throw new Error('No other images are valid');
    }

    return ( possible code below )
}

Defer - Это работало хорошо, пока я не понял, что создаст новый экземпляр для каждого подписчика. 

defer(() => {
    if (!preload) {
        this.is.loading.next(true);
    }
    return this.loadImage(this.slideshow[nextIndex]).pipe(
        finalize(() => {
            if (!preload) {
                this.is.loading.next(false);
            }
        }),
        map(() => nextIndex),
        catchError(err => this.loadNextImage(nextIndex)),
    );
});

Of(void 0).pipe(mergeMap(...)) - Это делает то, что должно, но это действительно некрасиво 

of(void 0).pipe(
    mergeMap(() => {
        if (!preload) {
            this.is.loading.next(true);
        }

        return this.loadImage(this.slideshow[nextIndex]).pipe(
            finalize(() => {
                if (!preload) {
                    this.is.loading.next(false);
                }
            }),
            map(() => nextIndex),
            catchError(err => this.loadNextImage(nextIndex)),
        );
    }),
)

new Observable - Я думаю, что должно быть решение, которого мне не хватает

...