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
  • Field Details

  • Constructor Details

    • HttpReceiverOverHTTP2

      public HttpReceiverOverHTTP2(org.eclipse.jetty.client.HttpChannel channel)
  • Method Details

    • getHttpChannel

      protected HttpChannelOverHTTP2 getHttpChannel()
      Overrides:
      getHttpChannel in class org.eclipse.jetty.client.HttpReceiver
    • receive

      protected void receive()
      Overrides:
      receive in class org.eclipse.jetty.client.HttpReceiver
    • reset

      protected void reset()
      Overrides:
      reset in class org.eclipse.jetty.client.HttpReceiver
    • onNewStream

      public void onNewStream(Stream stream)
      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 interface Stream.Listener
      Parameters:
      stream - the newly created stream
    • onHeaders

      public void onHeaders(Stream stream, HeadersFrame frame)
      Description copied from interface: Stream.Listener

      Callback method invoked when a HEADERS frame representing the HTTP response has been received.

      Specified by:
      onHeaders in interface Stream.Listener
      Parameters:
      stream - the stream
      frame - the HEADERS frame received
    • onPush

      public Stream.Listener onPush(Stream stream, PushPromiseFrame frame)
      Description copied from interface: Stream.Listener

      Callback method invoked when a PUSH_PROMISE frame has been received.

      Specified by:
      onPush in interface Stream.Listener
      Parameters:
      stream - the stream
      frame - the PUSH_PROMISE frame received
      Returns:
      a Stream.Listener that will be notified of pushed stream events
    • onData

      public void onData(Stream stream, DataFrame frame, org.eclipse.jetty.util.Callback callback)
      Description copied from interface: Stream.Listener

      Callback method invoked when a DATA frame has been received.

      Specified by:
      onData in interface Stream.Listener
      Parameters:
      stream - the stream
      frame - the DATA frame received
      callback - the callback to complete when the bytes of the DATA frame have been consumed
    • onReset

      public void onReset(Stream stream, ResetFrame frame)
      Description copied from interface: Stream.Listener

      Callback method invoked when a RST_STREAM frame has been received for this stream.

      Specified by:
      onReset in interface Stream.Listener
      Parameters:
      stream - the stream
      frame - the RST_FRAME received
      See Also:
    • onIdleTimeout

      public boolean onIdleTimeout(Stream stream, Throwable x)
      Description copied from interface: Stream.Listener

      Callback method invoked when the stream exceeds its idle timeout.

      Specified by:
      onIdleTimeout in interface Stream.Listener
      Parameters:
      stream - the stream
      x - 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 interface Stream.Listener
      Parameters:
      stream - the stream
      error - the error code
      reason - the error reason, or null
      failure - the failure
      callback - 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)