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 HttpChannelOverHTTP2
private void
notifyContent
(org.eclipse.jetty.client.HttpExchange exchange, DataFrame frame, org.eclipse.jetty.util.Callback callback) void
Callback method invoked when a DATA frame has been received.void
onFailure
(Stream stream, int error, String reason, Throwable failure, org.eclipse.jetty.util.Callback callback) Callback method invoked when the stream failed.void
onHeaders
(Stream stream, HeadersFrame frame) Callback method invoked when a HEADERS frame representing the HTTP response has been received.boolean
onIdleTimeout
(Stream stream, Throwable x) Callback method invoked when the stream exceeds its idle timeout.void
onNewStream
(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.void
onReset
(Stream stream, ResetFrame frame) Callback method invoked when a RST_STREAM frame has been received for this stream.protected void
receive()
protected void
reset()
Methods inherited from class org.eclipse.jetty.client.HttpReceiver
abort, demand, dispose, getHttpDestination, getHttpExchange, hasDemandOrStall, isFailed, responseBegin, responseContent, responseFailure, responseHeader, responseHeaders, responseSuccess, storeCookie, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods 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:
getHttpChannel
in classorg.eclipse.jetty.client.HttpReceiver
-
receive
protected void receive()- Overrides:
receive
in classorg.eclipse.jetty.client.HttpReceiver
-
reset
protected void reset()- Overrides:
reset
in classorg.eclipse.jetty.client.HttpReceiver
-
onNewStream
Description copied from interface:Stream.Listener
Callback method invoked when a stream is created locally by
Session.newStream(HeadersFrame, Promise, Listener)
.- Specified by:
onNewStream
in interfaceStream.Listener
- Parameters:
stream
- the newly created stream
-
onHeaders
Description copied from interface:Stream.Listener
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
- Specified by:
onHeaders
in interfaceStream.Listener
- Parameters:
stream
- the streamframe
- the HEADERS frame received
-
onPush
Description copied from interface:Stream.Listener
Callback method invoked when a PUSH_PROMISE frame has been received.
- Specified by:
onPush
in 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.Listener
Callback method invoked when a DATA frame has been received.
- Specified by:
onData
in 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.Listener
Callback method invoked when a RST_STREAM frame has been received for this stream.
- Specified by:
onReset
in interfaceStream.Listener
- Parameters:
stream
- the streamframe
- the RST_FRAME received- See Also:
-
onIdleTimeout
Description copied from interface:Stream.Listener
Callback method invoked when the stream exceeds its idle timeout.
- Specified by:
onIdleTimeout
in 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.Listener
Callback method invoked when the stream failed.
- Specified by:
onFailure
in 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)
-