Cancel the stream exchange on error

Parameters

throwable:Throwable

an exception to be relayed to the multi exchange through the completable future chain

error:Http3Error

an HTTP/3 error

Called at the end of handleResponse, to propagate the response to the multi exchange.

Parameters

response:Response

the Response that was received.

Notify of a connection error. The implementation of this method is supposed to close all exchanges, cancel all push promises, and close the connection.

connectionError(throwable, error.code(), throwable.getMessage());

Parameters

throwable:Throwable

an exception to be relayed to the multi exchange through the completable future chain

error:Http3Error

an HTTP/3 error

Notify of a connection error. The implementation of this method is supposed to close all exchanges, cancel all push promises, and close the connection.

Parameters

throwable:Throwable

an exception to be relayed to the multi exchange through the completable future chain

errorCode:long

an HTTP/3 error code

errMsg:String

an error message to be logged when closing the connection

Validate response headers and status code based on the responseState. If validated, this method will call newResponse(HttpHeaders, int) to create a Response object, which it will then pass to completeResponse(Response).

Parameters

responseHeadersBuilder:HttpHeadersBuilder

the response headers builder

rspHeadersConsumer:Http3Stream<T>.StreamHeadersConsumer

the response headers consumer

readScheduler:SequentialScheduler

the read scheduler

debug:Logger

the debug logger

Called to create a new Response object for the newly receive response headers and response status code. This method is called from handleResponse, after the status code and headers have been validated.

Parameters

responseHeaders:HttpHeaders

response headers

responseCode:int

response code

Returns:Response

a new Response object

Called when an exception is thrown by reader::poll when called from processQuicData. This is typically only used for logging purposes.

Parameters

reader:QuicStreamReader

the stream reader

io:IOException

the exception caught

Called when processQuicData detects that the reader has been reset. This method should do the appropriate garbage collection, possibly closing the exchange or the connection if needed, and closing the read scheduler.

Invoked when some data is received from the underlying quic stream. This implements the read loop for a request-response stream or a push response stream.

Push response data to the response body subscriber if allowed by the subscription state.

Parameters

responseData:ConcurrentLinkedQueue<List<ByteBuffer>>

a queue of available data to be pushed to the subscriber

Returns whether reading from the quic stream is currently paused. Typically reading is paused when waiting for headers to be decoded by QPack.

Returns:boolean

whether reading from the quic stream is currently paused

Called when new payload data is received by processQuicData for a given header frame.

Any exception thrown here will be rethrown by processQuicData

Parameters

headers:HeadersFrame

a partially received header frame

payload:List<ByteBuffer>

the payload bytes available for that frame

Exceptions

IOException:

if an error is detected

Called when new payload data is received by processQuicData for a given push promise frame.

Any exception thrown here will be rethrown by processQuicData

Parameters

ppf:PushPromiseFrame

a partially received push promise frame

payload:List<ByteBuffer>

the payload bytes available for that frame

Exceptions

IOException:

if an error is detected

Returns the Quic stream id for this exchange (request/response or push response).

Returns:long

the Quic stream id for this exchange (request/response or push response)

Switches the value of the readingPaused flag

Subclasses of Http3Stream can call this method to switch the value of this flag if needed, typically in their concrete implementation of receiveHeaders(HeadersFrame, List).

Parameters

value:boolean

the new value