Added printRawBytes methods

android/src/main/java/com/example/bluetooth_print/BluetoothPrintPlugin.java

@@ -35,6 +35,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Vector;
 
 /** BluetoothPrintPlugin */
 public class BluetoothPrintPlugin implements FlutterPlugin, ActivityAware, MethodCallHandler, RequestPermissionsResultListener {
@@ -200,6 +201,10 @@ public void onMethodCall(MethodCall call, Result result) {
       case "destroy":
         result.success(destroy());
         break;
+      case "rawBytes":
+        Log.i("NATIVE","rawBytes");
+        printRawBytes(result,args);
+        break;
       case "print":
         print(result, args);
         break;
@@ -424,6 +429,40 @@ public void run() {
 
   }
 
+  private void printRawBytes(Result result, Map<String, Object> args) {
+    if (DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id] == null ||
+            !DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].getConnState()) {
+
+      result.error("not connect", "state not right", null);
+    }
+
+    if (args.containsKey("config") && args.containsKey("data")) {
+      final Map<String,Object> config = (Map<String,Object>)args.get("config");
+//      final List<Map<String,Object>> list = (List<Map<String,Object>>)args.get("data");
+      final byte [] bytes = (byte [])args.get("data");
+      if(bytes == null){
+        return;
+      }
+
+      threadPool = ThreadPool.getInstantiation();
+      threadPool.addSerialTask(new Runnable() {
+        @Override
+        public void run() {
+          if (DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].getCurrentPrinterCommand() == PrinterCommand.ESC) {
+            DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].sendByteDataImmediately(bytes);
+          }else if (DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].getCurrentPrinterCommand() == PrinterCommand.TSC) {
+            DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].sendByteDataImmediately(bytes);
+          }else if (DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].getCurrentPrinterCommand() == PrinterCommand.CPCL) {
+            DeviceConnFactoryManager.getDeviceConnFactoryManagers()[id].sendByteDataImmediately(bytes);
+          }
+        }
+      });
+    }else{
+      result.error("please add config or data", "", null);
+    }
+
+  }
+
   @Override
   public boolean onRequestPermissionsResult(int requestCode, String[] permissions, int[] grantResults) {
 

ios/Classes/BluetoothPrintPlugin.m

@@ -112,7 +112,17 @@ - (void)handleMethodCall:(FlutterMethodCall*)call result:(FlutterResult)result {
        } @catch(FlutterError *e) {
          result(e);
        }
-  } else if([@"printLabel" isEqualToString:call.method]) {
+  } else if([@"rawBytes" isEqualToString:call.method]) {
+      @try {
+        NSDictionary *args = [call arguments];
+        NSDictionary *config = [args objectForKey:@"config"];
+        FlutterStandardTypedData *list = [args objectForKey:@"data"];
+        [Manager write:list.data];
+        result(nil);
+      } @catch(FlutterError *e) {
+        result(e);
+      }
+ } else if([@"printLabel" isEqualToString:call.method]) {
      @try {
        NSDictionary *args = [call arguments];
        [Manager write:[self mapToTscCommand:args]];
@@ -250,23 +260,23 @@ -(void)updateConnectState:(ConnectState)state {
         NSNumber *ret = @0;
         switch (state) {
             case CONNECT_STATE_CONNECTING:
-                NSLog(@"status -> %@", @"连接状态：连接中....");
+                NSLog(@"status -> %@", @"Connection status: Connecting....");
                 ret = @0;
                 break;
             case CONNECT_STATE_CONNECTED:
-                NSLog(@"status -> %@", @"连接状态：连接成功");
+                NSLog(@"status -> %@", @"Connection status: successfully connected");
                 ret = @1;
                 break;
             case CONNECT_STATE_FAILT:
-                NSLog(@"status -> %@", @"连接状态：连接失败");
+                NSLog(@"status -> %@", @"Connection status: connection failed");
                 ret = @0;
                 break;
             case CONNECT_STATE_DISCONNECT:
-                NSLog(@"status -> %@", @"连接状态：断开连接");
+                NSLog(@"status -> %@", @"Connection status: disconnected");
                 ret = @0;
                 break;
             default:
-                NSLog(@"status -> %@", @"连接状态：连接超时");
+                NSLog(@"status -> %@", @"Connection status: connection timed out");
                 ret = @0;
                 break;
         }

lib/bluetooth_print.dart

@@ -1,4 +1,5 @@
 import 'dart:async';
+import 'dart:typed_data';
 
 import 'package:flutter/services.dart';
 import 'package:rxdart/rxdart.dart';
@@ -20,10 +21,9 @@ class BluetoothPrint {
       StreamController.broadcast();
 
   BluetoothPrint._() {
-    _channel.setMethodCallHandler((MethodCall call) {
+    _channel.setMethodCallHandler((MethodCall call) async {
       _methodStreamController.add(call);
-      return;
-    } as Future<dynamic> Function(MethodCall)?);
+    });
   }
 
   static BluetoothPrint _instance = new BluetoothPrint._();
@@ -44,15 +44,15 @@ class BluetoothPrint {
   Stream<bool> get isScanning => _isScanning.stream;
 
   BehaviorSubject<List<BluetoothDevice>> _scanResults =
-      BehaviorSubject.seeded([]);
+      BehaviorSubject.seeded(<BluetoothDevice>[]);
 
   Stream<List<BluetoothDevice>> get scanResults => _scanResults.stream;
 
   PublishSubject _stopScanPill = new PublishSubject();
 
   /// Gets the current state of the Bluetooth module
   Stream<int> get state async* {
-    yield await _channel.invokeMethod('state').then((s) => s);
+    yield (await _channel.invokeMethod('state') ?? -1);
 
     yield* _stateChannel.receiveBroadcastStream().map((s) => s);
   }
@@ -94,7 +94,8 @@ class BluetoothPrint {
         .doOnDone(stopScan)
         .map((map) {
       final device = BluetoothDevice.fromJson(Map<String, dynamic>.from(map));
-      final List<BluetoothDevice> list = _scanResults.value;
+      final List<BluetoothDevice> list =
+          _scanResults.value ?? <BluetoothDevice>[];
       int newIndex = -1;
       list.asMap().forEach((index, e) {
         if (e.address == device.address) {
@@ -131,6 +132,14 @@ class BluetoothPrint {
 
   Future<dynamic> disconnect() => _channel.invokeMethod('disconnect');
 
+  Future<dynamic> rawBytes(Map<String, dynamic> config, List<int> data) {
+    Map<String, Object> args = Map();
+    args['config'] = config;
+    args['data'] = Uint8List.fromList(data);
+    _channel.invokeMethod('rawBytes', args);
+    return Future.value(true);
+  }
+
   Future<dynamic> destroy() => _channel.invokeMethod('destroy');
 
   Future<dynamic> printReceipt(