org.eclipse.jetty.server

Class ByteBufferQueuedHttpInput

java.lang.Object

java.io.InputStream

javax.servlet.ServletInputStream

org.eclipse.jetty.server.HttpInput<T>

org.eclipse.jetty.server.QueuedHttpInput<ByteBuffer>

org.eclipse.jetty.server.ByteBufferQueuedHttpInput

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class ByteBufferQueuedHttpInput
extends QueuedHttpInput<ByteBuffer>

An implementation of HttpInput using ByteBuffer as items.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.server.HttpInput

HttpInput.State

Field Summary

Fields inherited from class org.eclipse.jetty.server.HttpInput

ASYNC, EARLY_EOF, EOF, STREAM

Constructor Summary

Constructors

Constructor and Description
ByteBufferQueuedHttpInput()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	consume(ByteBuffer item, int length) Consumes the given content.
protected int	get(ByteBuffer item, byte[] buffer, int offset, int length) Copies the given content into the given byte buffer.
protected void	onContentConsumed(ByteBuffer item) Callback that signals that the given content has been consumed.
protected int	remaining(ByteBuffer item)

Methods inherited from class org.eclipse.jetty.server.QueuedHttpInput

blockForContent, content, earlyEOF, messageComplete, nextContent, recycle

Methods inherited from class org.eclipse.jetty.server.HttpInput

available, consumeAll, failed, getContentRead, getNextContent, init, isAsync, isEarlyEOF, isEOF, isFinished, isReady, lock, onAsyncRead, read, read, run, setReadListener, unready

Methods inherited from class javax.servlet.ServletInputStream

readLine

Methods inherited from class java.io.InputStream

close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteBufferQueuedHttpInput

public ByteBufferQueuedHttpInput()

Method Detail

remaining

protected int remaining(ByteBuffer item)

Specified by:

remaining in class HttpInput<ByteBuffer>

Parameters:

item - the content

Returns:

how many bytes remain in the given content

get

protected int get(ByteBuffer item,
      byte[] buffer,
      int offset,
      int length)

Description copied from class: HttpInput

Copies the given content into the given byte buffer.

Specified by:

get in class HttpInput<ByteBuffer>

Parameters:

item - the content to copy from

buffer - the buffer to copy into

offset - the buffer offset to start copying from

length - the space available in the buffer

Returns:

the number of bytes actually copied

consume

protected void consume(ByteBuffer item,
           int length)

Description copied from class: HttpInput

Consumes the given content.

Specified by:

consume in class HttpInput<ByteBuffer>

Parameters:

item - the content to consume

length - the number of bytes to consume

onContentConsumed

protected void onContentConsumed(ByteBuffer item)

Description copied from class: QueuedHttpInput

Callback that signals that the given content has been consumed.

Specified by:

onContentConsumed in class QueuedHttpInput<ByteBuffer>

Parameters:

item - the consumed content