Specify readBufferSize in open method

Author: bastengao

android/src/main/java/com/bastengao/serialport/SerialPortApiModule.java

@@ -65,7 +65,7 @@ public void getSuPath(final Callback callback) {
     }
 
     @ReactMethod
-    public void open(final String path, int baudRate, int parity, int dataBits, int stopBits, Promise promise) {
+    public void open(final String path, int baudRate, int parity, int dataBits, int stopBits, int readBufferSize, Promise promise) {
         if (serialPorts.containsKey(path)) {
             promise.resolve(serialPorts.get(path).toJS());
             return;
@@ -85,7 +85,7 @@ public void remove() {
                     .stopBits(stopBits)
                     .build();
 
-            SerialPortWrapper wrapper = new SerialPortWrapper(path, serialPort, this, remover);
+            SerialPortWrapper wrapper = new SerialPortWrapper(path, readBufferSize, serialPort, this, remover);
 
             // TODO: handle previous value
             serialPorts.put(path, wrapper);

android/src/main/java/com/bastengao/serialport/SerialPortWrapper.java

@@ -26,7 +26,7 @@ public class SerialPortWrapper {
 
     private AtomicBoolean closed = new AtomicBoolean(false);
 
-    public SerialPortWrapper(String path, SerialPort serialPort, final EventSender sender, Remover remover) {
+    public SerialPortWrapper(final String path, final int readBufferSize, SerialPort serialPort, final EventSender sender, Remover remover) {
         this.path = path;
         this.serialPort = serialPort;
         this.sender = sender;
@@ -37,7 +37,7 @@ public SerialPortWrapper(String path, SerialPort serialPort, final EventSender s
         this.readThread = new Thread(new Runnable() {
             @Override
             public void run() {
-                byte[] buffer = new byte[64];
+                byte[] buffer = new byte[readBufferSize];
                 while (!closed.get()) {
                     try {
                         int size;

src/API.ts

@@ -22,6 +22,7 @@ export default class API {
    * @property {number} [parity=0] 0: none, 1: odd, 2: even
    * @property {number} [dataBits=8] 5~8
    * @property {number} [stopBits=1] 1 or 2
+   * @property {number} [readBufferSize=64] set read buffer size
    */
 
   /**
@@ -77,9 +78,9 @@ export default class API {
    * @param {openOptions} options
    * @returns {Promise<SerialPort>} connected serial port
    */
-  static open(devicePath: string, {baudRate, parity = 0, dataBits = 8, stopBits = 1}: { baudRate: number, parity?: number, dataBits?: number, stopBits?: number }): Promise<SerialPort> {
+  static open(devicePath: string, {baudRate, parity = 0, dataBits = 8, stopBits = 1, readBufferSize = 64}: { baudRate: number, parity?: number, dataBits?: number, stopBits?: number, readBufferSize?: number }): Promise<SerialPort> {
     if (Platform.OS !== 'android') throw new Error(`Not support ${Platform.OS}`)
-    return SerialPortAPI.open(devicePath, baudRate, parity, dataBits, stopBits)
+    return SerialPortAPI.open(devicePath, baudRate, parity, dataBits, stopBits, readBufferSize)
       .then((serialPort: SerialPortWrapper) => {
         return Promise.resolve(new SerialPort(serialPort, eventEmitter!));
       })