Method run

android/src/InputThread.java:88–116

()

  }

  @Override public void run() {
    byte[] buffer = new byte[BUFFER_SIZE];

    InputStream is2 = is;
    while (is2 != null) {
      int n;
      try {
        n = is2.read(buffer, 0, buffer.length);
      } catch (IOException e) {
        if (is != null)
          Log.e(TAG, "Failed to read from " + name, e);

        closeInternal();
        break;
      }

      if (n < 0)
        break;

      is2 = is;
      if (is2 == null)
        // close() was called
        break;

      InputListener listener2 = listener;
      if (listener2 != null)
        listener2.dataReceived(buffer, n);
    }
  }
}