src/app/operator/infinite-progress.operator.ts
Function infiniteProgress
has 34 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
export function infiniteProgress<T>(
onEnter?: (enter: { index: number; count: number; observable: Observable<T> }) => void,
onProgress?: (progress: { result: T; done: number; total: number; index: number }) => void,
onFinish?: () => void
): OperatorFunction<Observable<T>, T> {
Function progressOperation
has 32 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
return function progressOperation(source: Observable<Observable<T>>): Observable<T> {
return source.pipe(
mergeScan((acc, next) => of((acc.index = acc.count++) !== undefined && (acc.observable = next) && acc), {
index: 0,
count: 0,