нужно чтобы при измнении id который находится в сторе ngrx, массив progressArr обнулялся, можете подсказать или идейку подкинуть как это сделать? export function subscriptionInfoFactory(  
                  
                  
                    signalRTreatmentService: SignalRCalculationTreatmentService  
                  
                  
                    ): Observable<ICalculationProgress[]> {  
                  
                  
                    
                  
                  
                    const progressArr: ICalculationProgress[] = [];  
                  
                  
                    
                  
                  
                    return signalRTreatmentService.progressEvent$.pipe(  
                  
                  
                      switchMap((progress: ICalculationProgress[]) => {  
                  
                  
                        progress.forEach(progressInner => {  
                  
                  
                          const index = progressArr.findIndex(x => x.id === progressInner.id);  
                  
                  
                          if (index !== -1) {  
                  
                  
                            Object.assign(progressArr[index], progressInner);  
                  
                  
                          } else {  
                  
                  
                            progressArr.push(progressInner);  
                  
                  
                          }  
                  
                  
                        });  
                  
                  
                        return of(progressArr);  
                  
                  
                      }),  
                  
                  
                      )  
                  
                  
                  }
                  
                  
                
export function subscriptionInfoFactory( signalRTreatmentService: SignalRCalculationTreatmentService ): Observable<ICalculationProgress[]> { const progressArr: ICalculationProgress[] = []; return signalRTreatmentService.progressEvent$.pipe( switchMap((progress: ICalculationProgress[]) => { progress.forEach(progressInner => { const index = progressArr.findIndex(x => x.id === progressInner.id); if (index !== -1) { Object.assign(progressArr[index], progressInner); } else { progressArr.push(progressInner); } }); return of(progressArr); }), ) }
Стикер
Обсуждают сегодня