in http2/src/main/java/org/apache/mina/http2/impl/Http2PushPromiseFrameDecoder.java [66:105]
public boolean consume(ByteBuffer buffer) {
while ((getValue() == null) && buffer.remaining() > 0) {
switch (state) {
case PAD_LENGTH:
padLength = buffer.get();
state = State.PROMISED_STREAM;
decoder = new IntPartialDecoder(4);
break;
case PROMISED_STREAM:
if (decoder.consume(buffer)) {
builder.promisedStreamID(((IntPartialDecoder)decoder).getValue() & HTTP2_31BITS_MASK);
state = State.HEADER;
int headerLength = getHeader().getLength() - 4;
if (isFlagSet(FLAGS_PADDING)) {
headerLength -= (padLength + 1);
}
decoder = new BytePartialDecoder(headerLength);
}
break;
case HEADER:
if (decoder.consume(buffer)) {
builder.headerBlockFragment(((BytePartialDecoder)decoder).getValue());
if (isFlagSet(FLAGS_PADDING)) {
state = State.PADDING;
decoder = new BytePartialDecoder(padLength);
} else {
setValue(builder.build());
}
}
break;
case PADDING:
if (decoder.consume(buffer)) {
builder.padding(((BytePartialDecoder)decoder).getValue());
setValue(builder.build());
}
break;
}
}
return getValue() != null;
}