diff --git a/packages/binding-mqtt/src/mqtt-client.ts b/packages/binding-mqtt/src/mqtt-client.ts index 9f512488c..7cdc12d2a 100644 --- a/packages/binding-mqtt/src/mqtt-client.ts +++ b/packages/binding-mqtt/src/mqtt-client.ts @@ -66,7 +66,7 @@ export default class MqttClient implements ProtocolClient { await pool.connect(brokerUri, this.config); - pool.subscribe( + await pool.subscribe( filter, (topic: string, message: Buffer) => { next(new Content(contentType, Readable.from(message)));