src/app/operator/finite-progress.operator.ts
Function finiteProgress
has 39 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
export function finiteProgress<T>(
onStart?: (start: { total: number; observables: Array<Observable<T>> }) => void,
onProgress?: (progress: { result: T; done: number; total: number; index: number }) => void,
onFinish?: () => void
): OperatorFunction<Observable<T>, T> {
Function progressOperation
has 37 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
return function progressOperation(source: Observable<Observable<T>>): Observable<T> {
return source.pipe(
map(observable => ({ total: 0, observables: [observable] })),
reduce(
(acc, next) => {