ing
This commit is contained in:
@@ -17,16 +17,16 @@ export class NotificationService {
|
||||
|
||||
}
|
||||
|
||||
public readAllByMember(member: Member, pageParams: PageParams): Observable<Page<Notification>> {
|
||||
return this.rpcService.call('NotificationService.readAllByMember', member, pageParams);
|
||||
public readAllByMemberEmail(memberEmail: string, pageParams: PageParams): Observable<Page<Notification>> {
|
||||
return this.rpcService.call('NotificationService.readAllByMemberEmail', memberEmail, pageParams);
|
||||
}
|
||||
|
||||
public markAllAsRead(member: Member, pageParams: PageParams): Observable<Page<Notification>> {
|
||||
return this.rpcService.call('NotificationService.markAllAsRead', member, pageParams);
|
||||
public markAllAsReadByMemberEmail(memberEmail: string, pageParams: PageParams): Observable<Page<Notification>> {
|
||||
return this.rpcService.call('NotificationService.markAllAsReadByMemberEmail', memberEmail, pageParams);
|
||||
}
|
||||
|
||||
public markAsRead(notification: Notification): Observable<Notification> {
|
||||
return this.rpcService.call('NotificationService.markAsRead', notification);
|
||||
public markAsRead(notificationID: number): Observable<Notification> {
|
||||
return this.rpcService.call('NotificationService.markAsRead', notificationID);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -37,7 +37,7 @@ export class Effects {
|
||||
map((action: ReadAllByMember) => action.payload),
|
||||
exhaustMap(payload =>
|
||||
this.notificationService
|
||||
.readAllByMember(payload.member, payload.pageParams)
|
||||
.readAllByMemberEmail(payload.member.email, payload.pageParams)
|
||||
.pipe(
|
||||
map(page => {
|
||||
return new ReadAllByMemberSuccess(page);
|
||||
@@ -53,7 +53,7 @@ export class Effects {
|
||||
map((action: MarkAllAsRead) => action.payload),
|
||||
exhaustMap(payload =>
|
||||
this.notificationService
|
||||
.markAllAsRead(payload.member, payload.pageParams)
|
||||
.markAllAsReadByMemberEmail(payload.member.email, payload.pageParams)
|
||||
.pipe(
|
||||
map(page => {
|
||||
return new MarkAllAsReadSuccess(page);
|
||||
|
||||
Reference in New Issue
Block a user