public class GoAwayBodyParser extends BodyParser
Modifier and Type | Class and Description |
---|---|
private static class |
GoAwayBodyParser.State |
Modifier and Type | Field and Description |
---|---|
private int |
cursor |
private int |
error |
private int |
lastStreamId |
private int |
length |
private byte[] |
payload |
private GoAwayBodyParser.State |
state |
LOG
Constructor and Description |
---|
GoAwayBodyParser(HeaderParser headerParser,
Parser.Listener listener) |
Modifier and Type | Method and Description |
---|---|
private boolean |
onGoAway(int lastStreamId,
int error,
byte[] payload) |
boolean |
parse(java.nio.ByteBuffer buffer)
Parses the body bytes in the given
buffer ; only the body
bytes are consumed, therefore when this method returns, the buffer
may contain unconsumed bytes. |
private void |
reset() |
connectionFailure, emptyBody, getBodyLength, getStreamId, hasFlag, isEndStream, isPadding, notifyData, notifyGoAway, notifyHeaders, notifyPing, notifyPriority, notifyPushPromise, notifyReset, notifySettings, notifyWindowUpdate, streamFailure
private GoAwayBodyParser.State state
private int cursor
private int length
private int lastStreamId
private int error
private byte[] payload
public GoAwayBodyParser(HeaderParser headerParser, Parser.Listener listener)
private void reset()
public boolean parse(java.nio.ByteBuffer buffer)
BodyParser
Parses the body bytes in the given buffer
; only the body
bytes are consumed, therefore when this method returns, the buffer
may contain unconsumed bytes.
parse
in class BodyParser
buffer
- the buffer to parseprivate boolean onGoAway(int lastStreamId, int error, byte[] payload)