luneski/mqtt-explorer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Clean up

Browse Source
This commit is contained in:
Thomas Nordquist
2019-02-18 16:36:53 +01:00
parent 55ea381b3b
commit 24c6b7e7b3
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
events/EventBus.ts
View File

@@ -24,13 +24,13 @@ class IpcMainEventBus implements EventBusInterface {
public subscribe<MessageType>(subscribeEvent: Event<MessageType>, callback:(msg: MessageType) => void) { public subscribe<MessageType>(subscribeEvent: Event<MessageType>, callback:(msg: MessageType) => void) {
console.log('subscribing', subscribeEvent.topic) console.log('subscribing', subscribeEvent.topic)
this.ipc.on(subscribeEvent.topic, (event: any, arg: any) => { this.ipc.on(subscribeEvent.topic, (event: any, arg: any) => {
console.log(subscribeEvent.topic, arg)
this.client = event.sender this.client = event.sender
callback(arg) callback(arg)
}) })
} }
public unsubscribeAll<MessageType>(event: Event<MessageType>) { public unsubscribeAll<MessageType>(event: Event<MessageType>) {
console.log('unsubscribeAll', event.topic)
this.ipc.removeAllListeners(event.topic) this.ipc.removeAllListeners(event.topic)
} }
@@ -40,8 +40,6 @@ class IpcMainEventBus implements EventBusInterface {
public emit<MessageType>(event: Event<MessageType>, msg: MessageType) { public emit<MessageType>(event: Event<MessageType>, msg: MessageType) {
if (!this.client.isDestroyed()) { if (!this.client.isDestroyed()) {
console.log(event.topic, msg)
this.client.send(event.topic, msg) this.client.send(event.topic, msg)
} }
} }
@@ -83,7 +81,6 @@ class IpcRendererEventBus implements EventBusInterface {
} }
public emit<MessageType>(event: Event<MessageType>, msg: MessageType) { public emit<MessageType>(event: Event<MessageType>, msg: MessageType) {
console.log(event.topic, msg)
this.ipc.send(event.topic, msg) this.ipc.send(event.topic, msg)
} }
} }