StreamInputBuffer implementation, which is used when upgrading HTTP -> HTTP/2 connections.
| Modifier and Type | Field and Description |
|---|---|
| private boolean | |
| private final Http2Stream |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | close(Termination termination)
Implements org. Graceful input buffer close. |
| public synchronized boolean | isClosed()
Implements org. Returns true if the InputBuffer has been closed. |
| public boolean | offer(Buffer data, boolean isLast)
Implements org. The method is called, when new input data arrives. |
| public void | onReadEventComplete()
Implements org. The method will be invoked once upstream completes READ operation processing. |
| public HttpContent | poll()
Implements org. Retrieves available input buffer payload, waiting up to the
|
| public void | terminate(Termination termination)
Implements org. Forcibly closes the input buffer. |
| isClosed | back to summary |
|---|---|
| private boolean isClosed | |
| stream | back to summary |
|---|---|
| private final Http2Stream stream | |
| UpgradeInputBuffer | back to summary |
|---|---|
| pack-priv UpgradeInputBuffer(final Http2Stream stream) | |
| close | back to summary |
|---|---|
| public void close(Termination termination) Implements org. Doc from org. Graceful input buffer close. Marks the input buffer as closed by adding Termination input element to the input queue.
| |
| isClosed | back to summary |
|---|---|
| public synchronized boolean isClosed() Implements org. Doc from org. Returns true if the InputBuffer has been closed.
| |
| offer | back to summary |
|---|---|
| public boolean offer(Buffer data, boolean isLast) Implements org. Doc from org. The method is called, when new input data arrives.
| |
| onReadEventComplete | back to summary |
|---|---|
| public void onReadEventComplete() Implements org. Doc from org. 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 |
|---|---|
| public HttpContent poll() throws IOException Implements org. Doc from org. Retrieves available input buffer payload, waiting up to the
| |
| terminate | back to summary |
|---|---|
| public void terminate(Termination termination) Implements org. Doc from org. Forcibly closes the input buffer. All the buffered data will be discarded.
| |