public static interface MessageDeframer.Listener
Modifier and Type | Method and Description |
---|---|
void |
bytesRead(int numBytes)
Called when the given number of bytes has been read from the input source of the deframer.
|
void |
deframeFailed(Throwable cause)
Called when a
MessageDeframer.deframe(ReadableBuffer) operation failed. |
void |
deframerClosed(boolean hasPartialMessage)
Called when the deframer closes.
|
void |
messagesAvailable(StreamListener.MessageProducer producer)
Called to deliver the next complete message.
|
void bytesRead(int numBytes)
numBytes
- the number of bytes read from the deframer's input source.void messagesAvailable(StreamListener.MessageProducer producer)
producer
- single message producer wrapping the message.void deframerClosed(boolean hasPartialMessage)
hasPartialMessage
- whether the deframer contained an incomplete message at closing.void deframeFailed(Throwable cause)
MessageDeframer.deframe(ReadableBuffer)
operation failed.cause
- the actual failureCopyright © 2018. All rights reserved.