Вычитывание байтов из InputStream сокета Bluetooth

private class ReceiveDataThread extends Thread {
 
        public boolean stopThread = false;
        private InputStream inStream;
        //private BufferedReader bufferedReader; // not working
        private StringBuilder receivedString;
 
        public ReceiveDataThread(BluetoothSocket socket) {
            Log.d(TAG, "ReceiveDataThread :: ReceiveDataThread()");
 
            try {
                if (socket != null) {
                    inStream = socket.getInputStream();
                    //bufferedReader = new BufferedReader(new InputStreamReader(inStream));
                }
            } catch (IOException e) {
                Log.e(TAG, "input stream get failed: " + e.getMessage());
                if (listener != null) {
                    listener.onBluetoothError(ERROR_INPUTSTREAM_GET_FAILED);
                }
            }
 
        }
 
        @Override
        public void run() {
            Log.d(TAG, "ReceiveDataThread :: run()");
 
            //while (!stopThread) {
 
            // Read from the InputStream
            if (inStream != null) {
 
                byte[] buffer; //= new byte[bufferSize]; // buffer store for the stream
                int bytesAvailableCount = 0;
                int bytesReadCount = 0; // bytes returned from read()
 
                receivedString = new StringBuilder();
                String line = "";
 
                while (bytesReadCount >= 0 && !stopThread) {
 
                    try {
                        bytesAvailableCount = inStream.available();
                        Log.d(TAG, "bytesAvailableCount=" + bytesAvailableCount);
                        if (bytesAvailableCount == 0) {
 
                            if (receivedString.length() > 0) {
                                Log.d(TAG, "---------received string is ready: " + receivedString.toString() + "-----------");
                                final String tmpReceivedString = receivedString.toString();
                                receivedString.setLength(0);
                                //h.obtainMessage(RECEIVE_MESSAGE, bytes, -1, buffer).sendToTarget();     // Send to message queue Handler
                                uiHandler.post(new Runnable() {
 
                                    @Override
                                    public void run() {
                                        if (listener != null) {
                                            listener.onReceiveBluetoothData(tmpReceivedString);
                                        }
 
                                    }
                                });
 
                            }
                            continue;
                        }
                    } catch (IOException e1) {
                        Log.e(TAG, "an exception occured during available(): " + e1.getMessage());
                        if (listener != null) {
                            listener.onBluetoothError(ERROR_INPUTSTREAM_READ_FAILED);
                        }
                        break;
                    }
 
                    try {
 
                        //skipCount = 0;
                        Log.d(TAG, "bytesAvailableCount=" + bytesAvailableCount);
 
                        buffer = new byte[bytesAvailableCount];
 
                        // read is blocking and never returns "-1" : no end of input stream of bt socket
                        bytesReadCount = inStream.read(buffer, 0, buffer.length); // Get number of bytes and message in "buffer"
                        Log.d(TAG, "...read " + bytesReadCount + " bytes from InputStream");
 
                        if (bytesReadCount > 0) {
                            line = new String(buffer, 0, buffer.length, Charset.forName("UTF-8"));
                            //line = new String(buffer, Charset.forName("UTF-8"));
                            Log.d(TAG, "received line: " + line + ", appending to receivedString...");
                            receivedString.append(line);
                        }
 
                    } catch (IOException e2) {
                        Log.e(TAG, "an exception occurred during read: " + e2.getMessage());
                        if (listener != null) {
                            listener.onBluetoothError(ERROR_INPUTSTREAM_READ_FAILED);
                        }
                        break;
                    }
 
                }
 
            } else {
                Log.e(TAG, "inputstream is null");
                if (listener != null) {
                    listener.onBluetoothError(ERROR_INPUTSTREAM_GET_FAILED);
                }
                return;
            }
 
            //}
 
            Log.d(TAG, "closing inputStream");
            try {
                //bufferedReader.close();
                inStream.close();
            } catch (IOException e) {
                Log.d(TAG, "an exception occured during close()");
            }
        }
    }