Как объединить два наблюдаемых. Rx 6.2.2 - PullRequest
Новая
       1

Как объединить два наблюдаемых. Rx 6.2.2

0 голосов
/ 12 сентября 2018

У меня есть два вызова к бэкэнду, и мне нужно обрабатывать результат только тогда, когда оба ответа будут готовы: 

this.historyService.fetchBalance().subscribe((balance: Balance[]) => {
    this.servicesBalance = balance;
});

this.historyService.fetchOuts().subscribe((outs: History[]) => {
    this.outHistories = outs;
});

Я знаю forkJoin метод, но он возвращает массив и я потерял типы, что-то вроде этого: 

...subscribe([v1, v2] => ...)

Я хочу сохранить типы возвращаемых значений примерно так: 

...subscribe(balance: Balance[], outs: History[] => ...)

Как объединить наблюдаемые в моем случае? 

myQuestionUnionMethod(
    this.historyService.fetchBalance(),
    this.historyService.fetchOuts()
)
    .subscribe(balance: Balance[], outs: History[] => ...)

1 Ответ

0 голосов
/ 12 сентября 2018

Вы пробовали zip?Кажется, правильно введено : 

export function zip<T, T2>(v1: ObservableInput<T>, v2: ObservableInput<T2>): Observable<[T, T2]>;
export function zip<T, T2, T3>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>): Observable<[T, T2, T3]>;
export function zip<T, T2, T3, T4>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>): Observable<[T, T2, T3, T4]>;
export function zip<T, T2, T3, T4, T5>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>): Observable<[T, T2, T3, T4, T5]>;
export function zip<T, T2, T3, T4, T5, T6>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, v6: ObservableInput<T6>): Observable<[T, T2, T3, T4, T5, T6]>;

Если подумать, forkJoin также выглядит правильно напечатанным: 

export function forkJoin<T>(sources: [ObservableInput<T>]): Observable<T[]>;
export function forkJoin<T, T2>(sources: [ObservableInput<T>, ObservableInput<T2>]): Observable<[T, T2]>;
export function forkJoin<T, T2, T3>(sources: [ObservableInput<T>, ObservableInput<T2>, ObservableInput<T3>]): Observable<[T, T2, T3]>;
export function forkJoin<T, T2, T3, T4>(sources: [ObservableInput<T>, ObservableInput<T2>, ObservableInput<T3>, ObservableInput<T4>]): Observable<[T, T2, T3, T4]>;
export function forkJoin<T, T2, T3, T4, T5>(sources: [ObservableInput<T>, ObservableInput<T2>, ObservableInput<T3>, ObservableInput<T4>, ObservableInput<T5>]): Observable<[T, T2, T3, T4, T5]>;
export function forkJoin<T, T2, T3, T4, T5, T6>(sources: [ObservableInput<T>, ObservableInput<T2>, ObservableInput<T3>, ObservableInput<T4>, ObservableInput<T5>, ObservableInput<T6>]): Observable<[T, T2, T3, T4, T5, T6]>;
export function forkJoin<T>(sources: Array<ObservableInput<T>>): Observable<T[]>;

Что заставляет вас думать, что возвращаемое значение не являетсяправильно напечатан?У вас есть пример, где вы "потеряли типы"?

...