This commit is contained in:
Thomas Nordquist
2019-01-08 03:29:18 +01:00
parent 723666e2cb
commit 2a800dc7ca
17 changed files with 86 additions and 120 deletions

View File

@@ -1,7 +1,7 @@
import {
addMqttConnectionEvent, backendEvents,
makeConnectionStateEvent, removeConnection,
makeConnectionMessageEvent, AddMqttConnection
makeConnectionMessageEvent, AddMqttConnection,
} from '../../events'
import { MqttSource, DataSource } from './DataSource'
@@ -10,7 +10,7 @@ class ConnectionManager {
public manageConnections() {
backendEvents.subscribe(addMqttConnectionEvent, this.handleConnectionRequest)
backendEvents.subscribe(removeConnection, (connectionId) => this.removeConnection(connectionId))
backendEvents.subscribe(removeConnection, (connectionId: string) => this.removeConnection(connectionId))
}
private handleConnectionRequest = (event: AddMqttConnection) => {