code: public synchronized boolean sendData(byte[] bytes) {
  		if (bytes != null && bytes.length > 0 && !closed.get()) {
  			try {
  				if (listeners == null) {
  					buffer.addLast(bytes);
  				} else if (listeners.length == 1) {
  					listeners[0].onPacket(bytes, null, false);
  				} else {
  					for (PacketListener listener : listeners) {
  						listener.onPacket(bytes, null, false);
  					}
  				}
  				transferedBytes.addAndGet(bytes.length);
  			} catch (MoleculerError moleculerError) {
  				throw moleculerError;
  			} catch (Throwable error) {
  				throw new MoleculerClientError("Unable to send bytes to stream listener!", error, nodeID, null);
  			}
  			return true;
  		}
  		return false;
  	}
docs: --- SEND BYTES ---