We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 043bc74 commit e0e5baaCopy full SHA for e0e5baa
.gitignore
@@ -19,3 +19,4 @@ doc/api/
19
/example/
20
/coverage/
21
/bin/
22
+.DS_Store
lib/src/core/extension.dart
@@ -61,9 +61,10 @@ extension MqttClientX on MqttClient {
61
.updates
62
?.expand((events) => events)
63
?.asyncMap((event) {
64
- var _payload = event.payload as MqttPublishMessage;
65
- var payload =
66
- MqttPublishPayload.bytesToStringAsString(_payload.payload.message);
+ var p = event.payload as MqttPublishMessage;
+ var m = p.payload.message;
+ var payload = utf8.decode(m);
67
+
68
return tuple2(event.topic, payload);
69
});
70
}
0 commit comments