Package org.eclipse.jetty.http2.server.internal

Class HttpStreamOverHTTP2

java.lang.Object

org.eclipse.jetty.http2.server.internal.HttpStreamOverHTTP2

All Implemented Interfaces:

HTTP2Channel.Server, HttpStream, Callback, Invocable

public class HttpStreamOverHTTP2
extends Object
implements HttpStream, HTTP2Channel.Server

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback

Callback.Completable, Callback.Completing, Callback.Nested

Nested classes/interfaces inherited from interface org.eclipse.jetty.server.HttpStream

HttpStream.Wrapper

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Field Summary

Fields inherited from interface org.eclipse.jetty.util.Callback

NOOP

Fields inherited from interface org.eclipse.jetty.server.HttpStream

CONTENT_NOT_CONSUMED, UPGRADE_CONNECTION_ATTRIBUTE

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking

Constructor Summary

Constructors

Constructor	Description
HttpStreamOverHTTP2(HTTP2ServerConnection connection, HttpChannel httpChannel, HTTP2Stream stream)

Method Summary

Modifier and Type	Method	Description
Throwable	consumeAvailable()
void	demand()	Demands more content chunks to the underlying implementation.
void	failed(Throwable x)	Callback invoked when the operation fails.
String	getId()
long	getIdleTimeout()
TunnelSupport	getTunnelSupport()
boolean	isCommitted()
boolean	isIdle()
Runnable	onDataAvailable()
Runnable	onFailure(Throwable failure, Callback callback)
Runnable	onPushRequest(MetaData.Request request)
Runnable	onRequest(HeadersFrame frame)
void	onTimeout(TimeoutException timeout, BiConsumer<Runnable,Boolean> consumer)
Runnable	onTrailer(HeadersFrame frame)
void	prepareResponse(HttpFields.Mutable headers)	Prepare the response headers with respect to the stream.
void	push(MetaData.Request resource)	Pushes the given resource to the client.
Content.Chunk	read()	Reads a chunk of content, with the same semantic as Content.Source.read().
void	send(MetaData.Request request, MetaData.Response response, boolean last, ByteBuffer byteBuffer, Callback callback)	Send response meta-data and/or data.
void	setIdleTimeout(long idleTimeoutMs)
void	succeeded()	Callback invoked when the operation completes.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.Callback

completeWith

Methods inherited from interface org.eclipse.jetty.util.thread.Invocable

getInvocationType

Constructor Details

HttpStreamOverHTTP2

public HttpStreamOverHTTP2(HTTP2ServerConnection connection,
 HttpChannel httpChannel,
 HTTP2Stream stream)

Method Details

getId

public String getId()

Specified by:

getId in interface HttpStream

Returns:

an ID unique within the lifetime scope of the associated protocol connection. This may be a protocol ID (e.g. HTTP/2 stream ID) or it may be unrelated to the protocol.

onRequest

public Runnable onRequest(HeadersFrame frame)

read

public Content.Chunk read()

Description copied from interface: HttpStream

Reads a chunk of content, with the same semantic as Content.Source.read().

This method is called from the implementation of Request.read().

Specified by:

read in interface HttpStream

Returns:

a chunk of content, possibly with non-null Content.Chunk.getFailure() or null.

demand

public void demand()

Description copied from interface: HttpStream

Demands more content chunks to the underlying implementation.

This method is called from the implementation of Request.demand(Runnable) and when the demand can be satisfied the implementation must call HttpChannel.onContentAvailable(). If there is a problem meeting demand, then the implementation must call HttpChannel.onFailure(Throwable).

Specified by:

demand in interface HttpStream

See Also:

• HttpChannel.onContentAvailable()
• HttpChannel.onFailure(Throwable)

onDataAvailable

public Runnable onDataAvailable()

Specified by:

onDataAvailable in interface HTTP2Channel.Server

onTrailer

public Runnable onTrailer(HeadersFrame frame)

Specified by:

onTrailer in interface HTTP2Channel.Server

prepareResponse

public void prepareResponse(HttpFields.Mutable headers)

Description copied from interface: HttpStream

Prepare the response headers with respect to the stream. Typically this may set headers related to protocol specific behaviour (e.g. Keep-Alive for HTTP/1.0 connections).

Specified by:

prepareResponse in interface HttpStream

Parameters:

headers - The headers to prepare.

send

public void send(MetaData.Request request,
 MetaData.Response response,
 boolean last,
 ByteBuffer byteBuffer,
 Callback callback)

Description copied from interface: HttpStream

Send response meta-data and/or data.

Specified by:

send in interface HttpStream

Parameters:

request - The request metadata for which the response should be sent.

response - The response metadata to be sent or null if the response is already committed by a previous call to send.

last - True if this will be the last call to send and the response can be completed.

byteBuffer - A buffer of content to send or null if no content.

callback - The callback to invoke when the send is completed successfully or in failure.

getIdleTimeout

public long getIdleTimeout()

Specified by:

getIdleTimeout in interface HttpStream

setIdleTimeout

public void setIdleTimeout(long idleTimeoutMs)

Specified by:

setIdleTimeout in interface HttpStream

push

public void push(MetaData.Request resource)

Description copied from interface: HttpStream

Pushes the given resource to the client.

Specified by:

push in interface HttpStream

Parameters:

resource - the resource to push

See Also:

• ConnectionMetaData.isPushSupported()

onPushRequest

public Runnable onPushRequest(MetaData.Request request)

isCommitted

public boolean isCommitted()

Specified by:

isCommitted in interface HttpStream

isIdle

public boolean isIdle()

Specified by:

isIdle in interface HTTP2Channel.Server

getTunnelSupport

public TunnelSupport getTunnelSupport()

Specified by:

getTunnelSupport in interface HttpStream

consumeAvailable

public Throwable consumeAvailable()

Specified by:

consumeAvailable in interface HttpStream

onTimeout

public void onTimeout(TimeoutException timeout,
 BiConsumer<Runnable,Boolean> consumer)

Specified by:

onTimeout in interface HTTP2Channel.Server

onFailure

public Runnable onFailure(Throwable failure,
 Callback callback)

Specified by:

onFailure in interface HTTP2Channel.Server

succeeded

public void succeeded()

Description copied from interface: Callback

Callback invoked when the operation completes.

Specified by:

succeeded in interface Callback

See Also:

• Callback.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from interface: Callback

Callback invoked when the operation fails.

Specified by:

failed in interface Callback

Parameters:

x - the reason for the operation failure