Еще один наркоманский вариант function retryUntil<T, O>( project: (index:

Question

Еще один наркоманский вариант function retryUntil<T, O>( project: (index:

number) => Observable<O>,
condition: (data: O, index: number) => boolean
): Observable<O> {
return of(undefined).pipe(
expand((data: O, i: number): Observable<O> =>
i > 0 && condition(data, i)
? EMPTY
: project(i)),
filter(condition)
);
}

// пример
const retryLoadUntil = params =>
retryUntil(() => load(params), notNull);
source.pipe(switchMap(retryLoadUntil))