public class ByteBufferQueuedHttpInput extends QueuedHttpInput<ByteBuffer>
An implementation of HttpInput using ByteBuffer
as items.
HttpInput.State
Constructor and Description |
---|
ByteBufferQueuedHttpInput() |
Modifier and Type | Method and Description |
---|---|
protected void |
consume(ByteBuffer item,
int length) |
protected int |
get(ByteBuffer item,
byte[] buffer,
int offset,
int length) |
protected void |
onContentConsumed(ByteBuffer item) |
protected int |
remaining(ByteBuffer item) |
blockForContent, content, earlyEOF, messageComplete, nextContent, onAllContentConsumed, recycle
available, consumeAll, failed, getContentRead, getNextContent, init, isFinished, isReady, lock, onAsyncRead, read, read, run, setReadListener, unready
readLine
close, mark, markSupported, read, reset, skip
protected int remaining(ByteBuffer item)
remaining
in class HttpInput<ByteBuffer>
protected int get(ByteBuffer item, byte[] buffer, int offset, int length)
get
in class HttpInput<ByteBuffer>
protected void consume(ByteBuffer item, int length)
consume
in class HttpInput<ByteBuffer>
protected void onContentConsumed(ByteBuffer item)
onContentConsumed
in class QueuedHttpInput<ByteBuffer>
Copyright © 1995-2013 Mort Bay Consulting. All Rights Reserved.