diff --git a/projects/ucap-webmessenger-app/src/app/store/messenger/sync/effects.ts b/projects/ucap-webmessenger-app/src/app/store/messenger/sync/effects.ts index e760bb46..a6ea6f4a 100644 --- a/projects/ucap-webmessenger-app/src/app/store/messenger/sync/effects.ts +++ b/projects/ucap-webmessenger-app/src/app/store/messenger/sync/effects.ts @@ -9,7 +9,8 @@ import { map, withLatestFrom, switchMap, - tap + tap, + concatMap } from 'rxjs/operators'; import { Store, select } from '@ngrx/store'; @@ -163,7 +164,7 @@ export class Effects { tap(() => { groupList = []; }), - exhaustMap(req => { + concatMap(req => { return this.syncProtocolService.group2(req).pipe( map(res => { switch (res.SSVC_TYPE) { @@ -1082,7 +1083,7 @@ export class Effects { select((state: any) => state.messenger.sync.group2.syncDate as string) ) ), - exhaustMap(([req, syncDate]) => + concatMap(([req, syncDate]) => this.groupProtocolService.update2(req).pipe( map((res: GroupUpdateResponse) => { return group2({