Grizzly NIO 5.0.2 · org.glassfish.grizzly.http2.StreamInputBuffer

Method Summary

Modifier and Type	Method and Description
public void	close(final Termination termination) Graceful input buffer close.
public boolean	isClosed() Returns `true` if the `InputBuffer` has been closed.
public boolean	offer(final Buffer data, final boolean isLast) The method is called, when new input data arrives.
public void	onReadEventComplete() The method will be invoked once upstream completes READ operation processing.
public HttpContent	poll() Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available.
public void	terminate(final Termination termination) Forcibly closes the input buffer.

close	back to summary
public void close(final Termination termination) Graceful input buffer close. Marks the input buffer as closed by adding Termination input element to the input queue.

isClosed	back to summary
public boolean isClosed() Returns `true` if the `InputBuffer` has been closed.

offer	back to summary
public boolean offer(final Buffer data, final boolean isLast) The method is called, when new input data arrives.

onReadEventComplete	back to summary
public void onReadEventComplete() The method will be invoked once upstream completes READ operation processing. Here we have to simulate NIO OP_READ event re-registration.

poll back to summary

poll	back to summary
public HttpContent poll() throws IOException Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available. Exceptions IOException: if an error occurs during the poll operation.

public HttpContent poll() throws IOException

Retrieves available input buffer payload, waiting up to the Connection#getReadTimeout(java.util.concurrent.TimeUnit) wait time if necessary for payload to become available.

Exceptions

terminate	back to summary
public void terminate(final Termination termination) Forcibly closes the input buffer. All the buffered data will be discarded.