From bb527dcb65911da70af6ea2d07ad2466f53c9a7e Mon Sep 17 00:00:00 2001 From: leejh Date: Thu, 24 Oct 2019 10:51:50 +0900 Subject: [PATCH] =?UTF-8?q?bug=20fix=20::=20=EB=8C=80=ED=99=94=EB=B0=A9=20?= =?UTF-8?q?=EC=9D=BD=EC=9D=8C=20=EC=B2=98=EB=A6=AC=20=EB=B2=84=EA=B7=B8=20?= =?UTF-8?q?=EC=88=98=EC=A0=95.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/app/store/messenger/event/effects.ts | 27 +++++++++---------- 1 file changed, 12 insertions(+), 15 deletions(-) diff --git a/projects/ucap-webmessenger-app/src/app/store/messenger/event/effects.ts b/projects/ucap-webmessenger-app/src/app/store/messenger/event/effects.ts index faa9efdb..c0631f7f 100644 --- a/projects/ucap-webmessenger-app/src/app/store/messenger/event/effects.ts +++ b/projects/ucap-webmessenger-app/src/app/store/messenger/event/effects.ts @@ -123,21 +123,18 @@ export class Effects { { dispatch: false } ); - read$ = createEffect( - () => { - return this.actions$.pipe( - ofType(read), - switchMap(req => { - return this.eventProtocolService.read(req).pipe( - map((res: ReadResponse) => { - readNotification({ noti: res }); - }), - catchError(error => of(readFailure({ error }))) - ); - }) - ); - }, - { dispatch: false } + read$ = createEffect(() => + this.actions$.pipe( + ofType(read), + exhaustMap(req => + this.eventProtocolService.read(req).pipe( + map((res: ReadResponse) => { + return readNotification({ noti: res }); + }), + catchError(error => of(readFailure({ error }))) + ) + ) + ) ); readNotification$ = createEffect(