Class StompSubframeDecoder.Utf8LineParser

java.lang.Object

io.netty.handler.codec.stomp.StompSubframeDecoder.Utf8LineParser

All Implemented Interfaces:

ByteProcessor

Direct Known Subclasses:

StompSubframeDecoder.HeaderParser

Enclosing class:

StompSubframeDecoder

private static class StompSubframeDecoder.Utf8LineParser
extends Object
implements ByteProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface ByteProcessor

ByteProcessor.IndexNotOfProcessor, ByteProcessor.IndexOfProcessor

Field Summary

Fields

Modifier and Type	Field	Description
private final AppendableCharSequence	charSeq
private char	interim
private int	lineLength
private final int	maxLineLength
private boolean	nextRead

Fields inherited from interface ByteProcessor

FIND_ASCII_SPACE, FIND_COMMA, FIND_CR, FIND_CRLF, FIND_LF, FIND_LINEAR_WHITESPACE, FIND_NON_CR, FIND_NON_CRLF, FIND_NON_LF, FIND_NON_LINEAR_WHITESPACE, FIND_NON_NUL, FIND_NUL, FIND_SEMI_COLON

Constructor Summary

Constructors

Constructor	Description
Utf8LineParser(AppendableCharSequence charSeq, int maxLineLength)

Method Summary

Modifier and Type	Method	Description
protected void	appendTo(AppendableCharSequence charSeq, char chr)
(package private) AppendableCharSequence	charSequence()
(package private) AppendableCharSequence	parse(ByteBuf byteBuf)
boolean	process(byte nextByte)
protected void	reset()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

charSeq

private final AppendableCharSequence charSeq

maxLineLength

private final int maxLineLength

lineLength

private int lineLength

interim

private char interim

nextRead

private boolean nextRead

Constructor Details

Utf8LineParser

Utf8LineParser(AppendableCharSequence charSeq,
 int maxLineLength)

Method Details

parse

AppendableCharSequence parse(ByteBuf byteBuf)

charSequence

AppendableCharSequence charSequence()

process

public boolean process(byte nextByte)
                throws Exception

Specified by:

process in interface ByteProcessor

Returns:

true if the processor wants to continue the loop and handle the next byte in the buffer. false if the processor wants to stop handling bytes and abort the loop.

Throws:

Exception

appendTo

protected void appendTo(AppendableCharSequence charSeq,
 char chr)

reset

protected void reset()