public Class HttpReceiverOverHTTP3

Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.failAndClose.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.failAndClose.

Fails the receiver and closes the underlying stream.

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onDataAvailable.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onDataAvailable.

Callback method invoked if the application has expressed demand for content, and if there may be content available.

A server application that wishes to handle request content should typically call Stream#demand() from Session.Server.Listener#onRequest(Server, HeadersFrame).

A client application that wishes to handle response content should typically call Stream#demand() from Stream.Client.Listener#onResponse(Client, HeadersFrame).

Just prior calling this method, the outstanding demand is cancelled; applications that implement this method should read content calling Stream#readData(), and call Stream#demand() to signal to the implementation to call again this method when there may be more content available.

Only one thread at a time invokes this method, although it may not be the same thread across different invocations.

It is always guaranteed that invoking Stream#demand() from within this method will not cause a StackOverflowError.

Typical usage:

class MyStreamListener implements Stream.Client.Listener
{
    @Override
    public void onDataAvailable(Stream.Client stream)
    {
        // Read a chunk of the content.
        Stream.Data data = stream.readData();
        if (data == null)
        {
            // No data available now, demand to be called back.
            stream.demand();
        }
        else
        {
            // Process the content.
            process(data.getByteBuffer());
            // Notify that the content has been consumed.
            data.release();
            if (!data.isLast())
            {
                // Demand to be called back.
                stream.demand();
            }
        }
    }
}

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onFailure.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onFailure.

Callback method invoked when a stream failure occurred.

Typical stream failures, among others, are failures to decode a HEADERS frame, or failures to read bytes because the stream has been reset.

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onIdleTimeout.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onIdleTimeout.

Callback method invoked when the stream idle timeout elapses.

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onNewStream.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onNewStream.

Callback method invoked when a stream is created locally by Session.Client#newRequest(HeadersFrame, Listener).

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onResponse.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onResponse.

Callback method invoked when a response is received.

To read response content, applications should call Stream#demand() and override Stream.Client.Listener#onDataAvailable(Client).

Annotations

@Override

Overrides default org.eclipse.jetty.http3.api.Stream.Client.Listener.onTrailer.

Doc from org.eclipse.jetty.http3.api.Stream.Client.Listener.onTrailer.

Callback method invoked when a trailer is received.

Annotations

@Override

Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.read.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.read.

Reads a chunk of data.

If no data was read, null is returned and if fillInterestIfNeeded is true then fill interest is registered.

The returned chunk of data may be the last one or an error exactly like Content.Source#read() specifies.

Annotations

@Override