public class HttpReceiverOverHTTP2 extends HttpReceiver implements Stream.Listener
Modifier and Type | Class and Description |
---|---|
private class |
HttpReceiverOverHTTP2.ContentNotifier |
private static class |
HttpReceiverOverHTTP2.DataInfo |
Stream.Listener.Adapter
Modifier and Type | Field and Description |
---|---|
private HttpReceiverOverHTTP2.ContentNotifier |
contentNotifier |
LOG
Constructor and Description |
---|
HttpReceiverOverHTTP2(HttpChannel channel) |
Modifier and Type | Method and Description |
---|---|
protected HttpChannelOverHTTP2 |
getHttpChannel() |
private void |
notifyContent(HttpExchange exchange,
DataFrame frame,
Callback callback) |
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
private final HttpReceiverOverHTTP2.ContentNotifier contentNotifier
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 streamprivate void notifyContent(HttpExchange exchange, DataFrame frame, Callback callback)