public class HttpReceiverOverHTTP2 extends HttpReceiver implements Stream.Listener
Stream.Listener.Adapter
LOG
Constructor and Description |
---|
HttpReceiverOverHTTP2(HttpChannel channel) |
Modifier and Type | Method and Description |
---|---|
protected HttpChannelOverHTTP2 |
getHttpChannel() |
void |
onClosed(Stream stream)
Callback method invoked after the stream has been closed.
|
void |
onData(Stream stream,
DataFrame frame,
Callback callback)
Callback method invoked when a DATA frame has been received.
|
void |
onFailure(Stream stream,
int error,
java.lang.String reason,
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,
java.lang.Throwable x)
Callback method invoked when the stream exceeds its idle timeout.
|
Stream.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 |
reset()
Resets this
HttpReceiver state. |
abort, dispose, getHttpDestination, getHttpExchange, isFailed, responseBegin, responseContent, responseFailure, responseHeader, responseHeaders, responseSuccess, storeCookie, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
onReset, onTimeout
public HttpReceiverOverHTTP2(HttpChannel channel)
protected HttpChannelOverHTTP2 getHttpChannel()
getHttpChannel
in class HttpReceiver
protected void reset()
HttpReceiver
HttpReceiver
state.
Subclasses should override (but remember to call super
) to reset their own state.
Either this method or HttpReceiver.dispose()
is called.
reset
in class HttpReceiver
public void onHeaders(Stream stream, HeadersFrame frame)
Stream.Listener
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
onHeaders
in interface Stream.Listener
stream
- the streamframe
- the HEADERS frame receivedpublic Stream.Listener onPush(Stream stream, PushPromiseFrame frame)
Stream.Listener
Callback method invoked when a PUSH_PROMISE frame has been received.
onPush
in interface Stream.Listener
stream
- the streamframe
- the PUSH_PROMISE frame receivedpublic void onData(Stream stream, DataFrame frame, Callback callback)
Stream.Listener
Callback method invoked when a DATA frame has been received.
onData
in interface Stream.Listener
stream
- the streamframe
- the DATA frame receivedcallback
- the callback to complete when the bytes of the DATA frame have been consumedpublic void onReset(Stream stream, ResetFrame frame)
Stream.Listener
Callback method invoked when a RST_STREAM frame has been received for this stream.
onReset
in interface Stream.Listener
stream
- the streamframe
- the RST_FRAME receivedSession.Listener.onReset(Session, ResetFrame)
public boolean onIdleTimeout(Stream stream, java.lang.Throwable x)
Stream.Listener
Callback method invoked when the stream exceeds its idle timeout.
onIdleTimeout
in interface Stream.Listener
stream
- the streamx
- the timeout failureStream.getIdleTimeout()
public void onFailure(Stream stream, int error, java.lang.String reason, Callback callback)
Stream.Listener
Callback method invoked when the stream failed.
onFailure
in interface Stream.Listener
stream
- the streamerror
- the error codereason
- the error reason, or nullcallback
- the callback to complete when the failure has been handledpublic void onClosed(Stream stream)
Stream.Listener
Callback method invoked after the stream has been closed.
onClosed
in interface Stream.Listener
stream
- the streamCopyright © 1995–2023 Webtide. All rights reserved.