code: public void notifyOfError(Throwable error) {
  		if (error != null && this.error == null) {
  			this.error = error;
  
  			// this should wake up any blocking calls
  			try {
  				connectedSocket.close();
  			} catch (Throwable ignored) {}
  			try {
  				socket.close();
  			} catch (Throwable ignored) {}
  		}
  	}
docs: ------------------------------------------------------------------------