fix(binding-mqtt/mqtt-client): add missing await (#1275)

eclipse-thingweb · Apr 26, 2024 · af8263f · af8263f
1 parent f32ea33
commit af8263f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)));