Package org.eclipse.jetty.http2.client.transport.internal

Class HttpReceiverOverHTTP2

java.lang.Object

org.eclipse.jetty.client.transport.HttpReceiver

org.eclipse.jetty.http2.client.transport.internal.HttpReceiverOverHTTP2

All Implemented Interfaces:

HTTP2Channel.Client

public class HttpReceiverOverHTTP2
extends HttpReceiver
implements HTTP2Channel.Client

Constructor Summary

Constructors

Constructor	Description
HttpReceiverOverHTTP2(HttpChannel channel)

Method Summary

Modifier and Type	Method	Description
void	failAndClose(Throwable failure)	Fails the receiver and closes the underlying stream.
protected HttpChannelOverHTTP2	getHttpChannel()
Runnable	onDataAvailable()
Runnable	onFailure(Throwable failure, Callback callback)
protected void	onInterim()	Prepare for the next step after an interim response was read.
Runnable	onReset(ResetFrame frame, Callback callback)
Runnable	onTimeout(TimeoutException failure, Promise<Boolean> promise)
Content.Chunk	read(boolean fillInterestIfNeeded)	Reads a chunk of data.

Methods inherited from class org.eclipse.jetty.client.transport.HttpReceiver

abort, dispose, getHttpDestination, getHttpExchange, hasContent, isFailed, reset, responseBegin, responseContentAvailable, responseFailure, responseHeader, responseHeaders, responseSuccess, storeCookie, toString

Methods inherited from class java.lang.Object

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

Constructor Details

HttpReceiverOverHTTP2

public HttpReceiverOverHTTP2(HttpChannel channel)

Method Details

onInterim

protected void onInterim()

Description copied from class: HttpReceiver

Prepare for the next step after an interim response was read.

Specified by:

onInterim in class HttpReceiver

read

public Content.Chunk read(boolean fillInterestIfNeeded)

Description copied from class: HttpReceiver

Reads a chunk of data.

If no data was read, null is returned and if fillInterestIfNeeded is true then fill interest is registered.

The returned chunk of data may be the last one or an error exactly like Content.Source.read() specifies.

Specified by:

read in class HttpReceiver

Parameters:

fillInterestIfNeeded - true to register for fill interest when no data was read.

Returns:

the chunk of data that was read, or null if nothing was read.

failAndClose

public void failAndClose(Throwable failure)

Description copied from class: HttpReceiver

Fails the receiver and closes the underlying stream.

Specified by:

failAndClose in class HttpReceiver

Parameters:

failure - the failure.

getHttpChannel

protected HttpChannelOverHTTP2 getHttpChannel()

Overrides:

getHttpChannel in class HttpReceiver

onDataAvailable

public Runnable onDataAvailable()

Specified by:

onDataAvailable in interface HTTP2Channel.Client

onReset

public Runnable onReset(ResetFrame frame,
 Callback callback)

Specified by:

onReset in interface HTTP2Channel.Client

onTimeout

public Runnable onTimeout(TimeoutException failure,
 Promise<Boolean> promise)

Specified by:

onTimeout in interface HTTP2Channel.Client

onFailure

public Runnable onFailure(Throwable failure,
 Callback callback)

Specified by:

onFailure in interface HTTP2Channel.Client