in http2/src/main/java/org/apache/mina/http2/impl/Http2GoAwayFrameDecoder.java [58:87]
public boolean consume(ByteBuffer buffer) {
while ((getValue() == null) && buffer.remaining() > 0) {
switch (state) {
case LAST_STREAM_ID:
if (decoder.consume(buffer)) {
builder.lastStreamID(((IntPartialDecoder)decoder).getValue() & HTTP2_31BITS_MASK);
state = State.CODE;
decoder = new LongPartialDecoder(4);
}
case CODE:
if (decoder.consume(buffer)) {
builder.errorCode(((LongPartialDecoder)decoder).getValue());
if (getHeader().getLength() > 8) {
state = State.EXTRA;
decoder = new BytePartialDecoder(getHeader().getLength() - 8);
} else {
setValue(builder.build());
}
}
break;
case EXTRA:
if (decoder.consume(buffer)) {
builder.data(((BytePartialDecoder)decoder).getValue());
setValue(builder.build());
}
break;
}
}
return getValue() != null;
}