Skip to content

Commit

Permalink
Update _processMqttMessage method
Browse files Browse the repository at this point in the history
  • Loading branch information
Hecatoncheir committed Jul 28, 2017
1 parent e532ade commit d6fcd7d
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 1 deletion.
12 changes: 12 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
# See https://www.dartlang.org/tools/private-files.html

# Files and directories created by pub
.packages
.pub/
build/
# If you're building an application, you may want to check-in your pubspec.lock
pubspec.lock

# Directory created by dartdoc
# If you don't generate documentation locally you can remove this line.
doc/api/
3 changes: 2 additions & 1 deletion lib/mqtt_client.dart
Original file line number Diff line number Diff line change
Expand Up @@ -190,7 +190,8 @@ class MqttClient<E extends VirtualMqttConnection> {
*
* Return the data that has not been processed
*/
List<int> _processMqttMessage(data) {
List<int> _processMqttMessage(ByteBuffer details) {
var data = details.asInt8List();
num type = data[0] >> 4;
int msgProcessedLength = data.length;

Expand Down
1 change: 1 addition & 0 deletions lib/mqtt_shared.dart
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ import 'mqtt_version_v3.dart' ;
import "package:ini/ini.dart";
import 'dart:io';
import 'dart:convert';
import 'dart:typed_data';

part 'mqtt_client.dart';
part 'mqtt_connection_shared.dart';
Expand Down

0 comments on commit d6fcd7d

Please sign in to comment.