bug fix :: 대화방 읽음 처리 버그 수정.

This commit is contained in:
leejh 2019-10-24 10:51:50 +09:00
parent f5a4039bbf
commit bb527dcb65

View File

@ -123,21 +123,18 @@ export class Effects {
{ dispatch: false } { dispatch: false }
); );
read$ = createEffect( read$ = createEffect(() =>
() => { this.actions$.pipe(
return this.actions$.pipe(
ofType(read), ofType(read),
switchMap(req => { exhaustMap(req =>
return this.eventProtocolService.read(req).pipe( this.eventProtocolService.read(req).pipe(
map((res: ReadResponse) => { map((res: ReadResponse) => {
readNotification({ noti: res }); return readNotification({ noti: res });
}), }),
catchError(error => of(readFailure({ error }))) catchError(error => of(readFailure({ error })))
); )
}) )
); )
},
{ dispatch: false }
); );
readNotification$ = createEffect( readNotification$ = createEffect(