overflow_backup_2018_0455/overflow-webapp
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

accept deny button

Browse Source
This commit is contained in:
geek 2018-03-19 20:54:01 +09:00
parent c194b9ff1d
commit 1b879d1403
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/packages/discovery/store/notification/notification.effect.ts
View File

@ -14,7 +14,6 @@ import 'rxjs/add/operator/switchMap';
import 'rxjs/add/operator/map'; import 'rxjs/add/operator/map';
import 'rxjs/add/operator/take'; import 'rxjs/add/operator/take';
import { RPCError } from 'packages/core/rpc/error';
import { import {
DiscoverZone, DiscoverZone,
DiscoverHost, DiscoverHost,
@ -41,4 +40,27 @@ export class Effects {
this.discoveryService.discoverZone(payload.probeID, payload.discoveryZone); this.discoveryService.discoverZone(payload.probeID, payload.discoveryZone);
}); });
@Effect({ dispatch: false })
discoveryHost$ = this.actions$
.ofType(ActionType.DiscoverHost)
.map((action: DiscoverHost) => action.payload)
.do(payload => {
this.discoveryService.discoverHost(payload.probeID, payload.zone, payload.discoveryHost);
});
@Effect({ dispatch: false })
discoveryPort$ = this.actions$
.ofType(ActionType.DiscoverPort)
.map((action: DiscoverPort) => action.payload)
.do(payload => {
this.discoveryService.discoverPort(payload.probeID, payload.host, payload.discoveryPort);
});
@Effect({ dispatch: false })
discoveryService$ = this.actions$
.ofType(ActionType.DiscoverService)
.map((action: DiscoverService) => action.payload)
.do(payload => {
this.discoveryService.discoverService(payload.probeID, payload.port, payload.discoveryService);
});
} }