Erweiterungen
This commit is contained in:
1 parent
f764503d7e
commit
2d13a5f611
1 file changed
+1
-4
@@ -131,10 +131,7 @@ class MqttCore {
|
|||||||
|
|
||||||
publishText(String subtopic, String text) {
|
publishText(String subtopic, String text) {
|
||||||
try {
|
try {
|
||||||
var textBuffer = Uint8Buffer();
|
var compressedText = GZipCodec().encode(utf8.encode(text));
|
||||||
textBuffer.addAll(text.codeUnits);
|
|
||||||
|
|
||||||
var compressedText = GZipCodec().encode(text.codeUnits);
|
|
||||||
|
|
||||||
var mqttBuffer = Uint8Buffer();
|
var mqttBuffer = Uint8Buffer();
|
||||||
mqttBuffer.addAll(compressedText);
|
mqttBuffer.addAll(compressedText);
|
||||||
|
|||||||
Reference in new issue
Block a user