private class ReadThread extends Thread {

		@Override
		public void run() {
			super.run();
			try {
				synchronized(buffer) {
					while(!isInterrupted()) {
						//if(!isInterrupted()) {
							//byte[] buf = new byte[100];
							size = mInputStream.read(buffer);
							if (mInputStream != null && size > 0) {
								onDataReceived(buffer, size);
							}
						}
						else return;
					}
				}	
			}	
			catch (IOException e) {
				e.printStackTrace();
			} 
			catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		
		protected void onDataReceived(byte[] buf, int size) throws InterruptedException {
			//char[] buff = new char[size];

			synchronized(bf) {
				for(int j = 0; j < size; j++) {
					bf[j] = (char)buf[j];
				}
			}
			
			this.currentThread().sleep(5000);
					
		}
	}
		
	private class SendingThread extends Thread {
		
		@Override
		public void run() {
			try	{				
				synchronized(buffer) {
					while (!isInterrupted()) {
						if (mOutputStream != null) {
							mOutputStream.write(buffer);
						} 
						else return;
					} 
				}
			}
				
			catch (IOException e) {	
				e.printStackTrace();
				return;
			}
		}
	}