netifi-httpgateway/src/main/java/com/netifi/httpgateway/bridge/codec/ByteToMessageDecoder.java
/**
   * Called once data should be decoded from the given {@link ByteBuf}. This method will call {@link
   * #decode(ByteBuf, UnicastProcessor)} as long as decoding should take place.
   *
   * @param in the {@link ByteBuf} from which to read data
   * @param out the {@link UnicastProcessor} to which decoded messages should be added
   */
Called once data should be decoded from the given  ByteBuf. This method will call {@link
#decode(ByteBuf, UnicastProcessor)} as long as decoding should take place.

@param in the  ByteBuf from which to read data
@param out the  UnicastProcessor to which decoded messages should be added
Called once data should be decoded from the given ByteBuf . This method will call { @link #decode ( ByteBuf UnicastProcessor ) } as long as decoding should take place . @param in the ByteBuf from which to read data @param out the UnicastProcessor to which decoded messages should be added
protected void callDecode(ByteBuf in, UnicastProcessor<Object> out) {
    while (in.isReadable()) {
      int oldInputLength = in.readableBytes();
      decode(in, out);
      if (oldInputLength == in.readableBytes()) {
        break;
      }
    }
  }
protected void callDecode ( ByteBuf in , UnicastProcessor < Object > out ) { while ( in . isReadable ( ) ) { int oldInputLength = in . readableBytes ( ) ; decode ( in , out ) ; if ( oldInputLength == in . readableBytes ( ) ) { break ; } } }
Called once data should be decoded from the given {@link ByteBuf}.
Called once data should be decoded from the given { @link ByteBuf } .