Class HttpReceiverOverHTTP2
java.lang.Object
org.eclipse.jetty.client.HttpReceiver
org.eclipse.jetty.http2.client.http.HttpReceiverOverHTTP2
- All Implemented Interfaces:
Stream.Listener
public class HttpReceiverOverHTTP2
extends org.eclipse.jetty.client.HttpReceiver
implements Stream.Listener
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface org.eclipse.jetty.http2.api.Stream.Listener
Stream.Listener.Adapter -
Field Summary
FieldsFields inherited from class org.eclipse.jetty.client.HttpReceiver
LOG -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected HttpChannelOverHTTP2private voidnotifyContent(org.eclipse.jetty.client.HttpExchange exchange, DataFrame frame, org.eclipse.jetty.util.Callback callback) voidCallback method invoked when a DATA frame has been received.voidonFailure(Stream stream, int error, String reason, Throwable failure, org.eclipse.jetty.util.Callback callback) Callback method invoked when the stream failed.voidonHeaders(Stream stream, HeadersFrame frame) Callback method invoked when a HEADERS frame representing the HTTP response has been received.booleanonIdleTimeout(Stream stream, Throwable x) Callback method invoked when the stream exceeds its idle timeout.voidonNewStream(Stream stream) Callback method invoked when a stream is created locally bySession.newStream(HeadersFrame, Promise, Listener).onPush(Stream stream, PushPromiseFrame frame) Callback method invoked when a PUSH_PROMISE frame has been received.voidonReset(Stream stream, ResetFrame frame) Callback method invoked when a RST_STREAM frame has been received for this stream.protected voidreceive()protected voidreset()Methods inherited from class org.eclipse.jetty.client.HttpReceiver
abort, demand, dispose, getHttpDestination, getHttpExchange, hasDemandOrStall, isFailed, responseBegin, responseContent, responseFailure, responseHeader, responseHeaders, responseSuccess, storeCookie, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.jetty.http2.api.Stream.Listener
onClosed, onFailure, onReset, onTimeout
-
Field Details
-
contentNotifier
-
-
Constructor Details
-
HttpReceiverOverHTTP2
public HttpReceiverOverHTTP2(org.eclipse.jetty.client.HttpChannel channel)
-
-
Method Details
-
getHttpChannel
- Overrides:
getHttpChannelin classorg.eclipse.jetty.client.HttpReceiver
-
receive
protected void receive()- Overrides:
receivein classorg.eclipse.jetty.client.HttpReceiver
-
reset
protected void reset()- Overrides:
resetin classorg.eclipse.jetty.client.HttpReceiver
-
onNewStream
Description copied from interface:Stream.ListenerCallback method invoked when a stream is created locally by
Session.newStream(HeadersFrame, Promise, Listener).- Specified by:
onNewStreamin interfaceStream.Listener- Parameters:
stream- the newly created stream
-
onHeaders
Description copied from interface:Stream.ListenerCallback method invoked when a HEADERS frame representing the HTTP response has been received.
- Specified by:
onHeadersin interfaceStream.Listener- Parameters:
stream- the streamframe- the HEADERS frame received
-
onPush
Description copied from interface:Stream.ListenerCallback method invoked when a PUSH_PROMISE frame has been received.
- Specified by:
onPushin interfaceStream.Listener- Parameters:
stream- the streamframe- the PUSH_PROMISE frame received- Returns:
- a Stream.Listener that will be notified of pushed stream events
-
onData
Description copied from interface:Stream.ListenerCallback method invoked when a DATA frame has been received.
- Specified by:
onDatain interfaceStream.Listener- Parameters:
stream- the streamframe- the DATA frame receivedcallback- the callback to complete when the bytes of the DATA frame have been consumed
-
onReset
Description copied from interface:Stream.ListenerCallback method invoked when a RST_STREAM frame has been received for this stream.
- Specified by:
onResetin interfaceStream.Listener- Parameters:
stream- the streamframe- the RST_FRAME received- See Also:
-
onIdleTimeout
Description copied from interface:Stream.ListenerCallback method invoked when the stream exceeds its idle timeout.
- Specified by:
onIdleTimeoutin interfaceStream.Listener- Parameters:
stream- the streamx- the timeout failure- Returns:
- true to reset the stream, false to ignore the idle timeout
- See Also:
-
onFailure
public void onFailure(Stream stream, int error, String reason, Throwable failure, org.eclipse.jetty.util.Callback callback) Description copied from interface:Stream.ListenerCallback method invoked when the stream failed.
- Specified by:
onFailurein interfaceStream.Listener- Parameters:
stream- the streamerror- the error codereason- the error reason, or nullfailure- the failurecallback- the callback to complete when the failure has been handled
-
notifyContent
private void notifyContent(org.eclipse.jetty.client.HttpExchange exchange, DataFrame frame, org.eclipse.jetty.util.Callback callback)
-