OpenJDK 27 · jdk.internal.net.http.ExchangeImpl · APIdia, the JavaDoc alternative

Modifier and Type	Field and Description
private static final Logger	debug
pack-priv final Exchange<T>	exchange
private volatile boolean	expectTimeoutRaised

Access	Constructor and Description
pack-priv	ExchangeImpl(Exchange<T> e)

Method Summary

Modifier and Type	Method and Description
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	attemptHttp2Exchange(Exchange<U> exchange, HttpConnection connection)
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	attemptHttp3Exchange(Exchange<U> exchange, HttpConnection connection)
pack-priv abstract void	cancel() Cancels a request.
pack-priv abstract void	cancel(IOException cause) Cancels a request with a cause.
pack-priv static boolean	Returns: `true`, if it is allowed to cancel the request timer on response body subscriber termination; `false`, otherwise cancelTimerOnResponseBodySubscriberTermination(boolean indicates if the associated request is a WebSocket handshake webSocket, int the status code of the associated response statusCode) Returns `true`, if it is allowed to cancel the request timer on response body subscriber termination; `false`, otherwise.
private static <U, T extends ExchangeImpl<U>> T	checkCancelled(T exchangeImpl)
pack-priv HttpClientImpl	client()
pack-priv abstract void	completed() Called when the exchange is completed, so that cleanup actions may be performed - such as deregistering callbacks.
pack-priv abstract HttpConnection	connection() Returns the `HttpConnection` instance to which this exchange is assigned.
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	createExchangeImpl(Http3Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	createExchangeImpl(Http2Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)
private static <T> CompletableFuture<Http1Exchange<T>>	createHttp1Exchange(Exchange<T> ex, HttpConnection as)
pack-priv HttpBodySubscriberWrapper<T>	Returns: a new `HttpBodySubscriberWrapper` to handle the response createResponseSubscriber(HttpResponse.BodyHandler<T> a body handler handler, HttpResponse.ResponseInfo a response info response) Creates and wraps an `HttpResponse.BodySubscriber` from a `HttpResponse.BodyHandler` for the given `ResponseInfo`.
pack-priv void	expectContinueFailed(int rcode)
pack-priv final boolean	expectTimeoutRaised()
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	fallbackToHttp1OnTimeout(Http3Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)
private static <U> CompletableFuture<? extends ExchangeImpl<U>>	firstToComplete(Exchange<U> exchange, HttpConnection connection, Supplier<CompletableFuture<Http2Connection>> c2fs, CompletableFuture<Http3Connection> c3f)
pack-priv static <U> CompletableFuture<? extends ExchangeImpl<U>>	get(Exchange<U> exchange, HttpConnection connection) Initiates a new exchange and assigns it to a connection if one exists already.
pack-priv abstract Throwable	Returns: the cause for which this exchange was canceled, if available. getCancelCause() Returns the cause for which this exchange was canceled, if available.
pack-priv final Exchange<T>	getExchange()
pack-priv abstract CompletableFuture<Response>	getResponseAsync(Executor executor) Gets the response headers.
pack-priv abstract CompletableFuture<Void>	ignoreBody() Ignore/consume the body.
pack-priv abstract boolean	Returns: true if this exchange was canceled. isCanceled() Returns true if this exchange was canceled.
private static boolean	isTCP(HttpConnection connection)
pack-priv void	nullBody(HttpResponse<T> resp, Throwable t)
pack-priv abstract void	onProtocolError(IOException The cause of the protocol violation cause) Invoked whenever there is a (HTTP) protocol error when dealing with the response from the server.
pack-priv abstract CompletableFuture<T>	readBodyAsync(HttpResponse.BodyHandler<T> handler, boolean returnConnectionToPool, Executor executor)
pack-priv abstract void	released() Called when the exchange is released, so that cleanup actions may be performed - such as deregistering callbacks.
pack-priv abstract CompletableFuture<ExchangeImpl<T>>	sendBodyAsync() Sends a request body, after request headers have been sent.
pack-priv abstract CompletableFuture<ExchangeImpl<T>>	sendHeadersAsync()
pack-priv final void	setExpectTimeoutRaised()
pack-priv void	upgraded()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

debug	back to summary
private static final Logger debug

exchange	back to summary
pack-priv final Exchange<T> exchange

expectTimeoutRaised	back to summary
private volatile boolean expectTimeoutRaised

ExchangeImpl	back to summary
pack-priv ExchangeImpl(Exchange<T> e)

Method Detail

attemptHttp2Exchange	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> attemptHttp2Exchange(Exchange<U> exchange, HttpConnection connection)

attemptHttp3Exchange	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> attemptHttp3Exchange(Exchange<U> exchange, HttpConnection connection)

cancel	back to summary
pack-priv abstract void cancel() Cancels a request. Not currently exposed through API.

cancel	back to summary
pack-priv abstract void cancel(IOException cause) Cancels a request with a cause. Not currently exposed through API.

cancelTimerOnResponseBodySubscriberTermination back to summary

cancelTimerOnResponseBodySubscriberTermination	back to summary
pack-priv static boolean cancelTimerOnResponseBodySubscriberTermination(boolean webSocket, int statusCode) Returns `true`, if it is allowed to cancel the request timer on response body subscriber termination; `false`, otherwise. Parameters webSocket:boolean indicates if the associated request is a WebSocket handshake statusCode:int the status code of the associated response Returns:boolean `true`, if it is allowed to cancel the request timer on response body subscriber termination; `false`, otherwise

pack-priv static boolean cancelTimerOnResponseBodySubscriberTermination(boolean webSocket, int statusCode)

Returns true, if it is allowed to cancel the request timer on response body subscriber termination; false, otherwise.

Parameters

webSocket:boolean: indicates if the associated request is a WebSocket handshake
statusCode:int: the status code of the associated response

Returns:boolean

true, if it is allowed to cancel the request timer on response body subscriber termination; false, otherwise

checkCancelled	back to summary
private static <U, T extends ExchangeImpl<U>> T checkCancelled(T exchangeImpl)

client	back to summary
pack-priv HttpClientImpl client()

completed	back to summary
pack-priv abstract void completed() Called when the exchange is completed, so that cleanup actions may be performed - such as deregistering callbacks. Typically, completed is called at the end of the exchange, when the final response body has been received (or an error has caused the completion of the exchange).

connection	back to summary
pack-priv abstract HttpConnection connection() Returns the `HttpConnection` instance to which this exchange is assigned.

createExchangeImpl	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> createExchangeImpl(Http3Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)

createExchangeImpl	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> createExchangeImpl(Http2Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)

createHttp1Exchange	back to summary
private static <T> CompletableFuture<Http1Exchange<T>> createHttp1Exchange(Exchange<T> ex, HttpConnection as)

createResponseSubscriber back to summary

createResponseSubscriber	back to summary
pack-priv HttpBodySubscriberWrapper<T> createResponseSubscriber(HttpResponse.BodyHandler<T> handler, HttpResponse.ResponseInfo response) Creates and wraps an `HttpResponse.BodySubscriber` from a `HttpResponse.BodyHandler` for the given `ResponseInfo`. An `HttpBodySubscriberWrapper` wraps a response body subscriber and makes sure its completed/onError methods are called only once, and that its onSusbscribe is called before onError. This is useful when errors occur asynchronously, and most typically when the error occurs before the `BodySubscriber` has subscribed. Parameters handler:HttpResponse.BodyHandler<T> a body handler response:HttpResponse.ResponseInfo a response info Returns:HttpBodySubscriberWrapper<T> a new `HttpBodySubscriberWrapper` to handle the response

pack-priv HttpBodySubscriberWrapper<T> createResponseSubscriber(HttpResponse.BodyHandler<T> handler, HttpResponse.ResponseInfo response)

Creates and wraps an HttpResponse.BodySubscriber from a HttpResponse.BodyHandler for the given ResponseInfo. An HttpBodySubscriberWrapper wraps a response body subscriber and makes sure its completed/onError methods are called only once, and that its onSusbscribe is called before onError. This is useful when errors occur asynchronously, and most typically when the error occurs before the BodySubscriber has subscribed.

Parameters

handler:HttpResponse.BodyHandler<T>: a body handler
response:HttpResponse.ResponseInfo: a response info

Returns:HttpBodySubscriberWrapper<T>

a new HttpBodySubscriberWrapper to handle the response

expectContinueFailed	back to summary
pack-priv void expectContinueFailed(int rcode)

expectTimeoutRaised	back to summary
pack-priv final boolean expectTimeoutRaised()

fallbackToHttp1OnTimeout	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> fallbackToHttp1OnTimeout(Http3Connection c, Throwable t, Exchange<U> exchange, HttpConnection connection)

firstToComplete	back to summary
private static <U> CompletableFuture<? extends ExchangeImpl<U>> firstToComplete(Exchange<U> exchange, HttpConnection connection, Supplier<CompletableFuture<Http2Connection>> c2fs, CompletableFuture<Http3Connection> c3f)

get	back to summary
pack-priv static <U> CompletableFuture<? extends ExchangeImpl<U>> get(Exchange<U> exchange, HttpConnection connection) Initiates a new exchange and assigns it to a connection if one exists already. connection usually null.

getCancelCause	back to summary
pack-priv abstract Throwable getCancelCause() Returns the cause for which this exchange was canceled, if available. Returns:Throwable the cause for which this exchange was canceled, if available.

getCancelCause

back to summary

pack-priv abstract Throwable getCancelCause()

Returns the cause for which this exchange was canceled, if available.

Returns:Throwable: the cause for which this exchange was canceled, if available.

getExchange	back to summary
pack-priv final Exchange<T> getExchange()

getResponseAsync	back to summary
pack-priv abstract CompletableFuture<Response> getResponseAsync(Executor executor) Gets the response headers. Completes before body is read.

ignoreBody	back to summary
pack-priv abstract CompletableFuture<Void> ignoreBody() Ignore/consume the body.

isCanceled	back to summary
pack-priv abstract boolean isCanceled() Returns true if this exchange was canceled. Returns:boolean true if this exchange was canceled.

isCanceled

back to summary

pack-priv abstract boolean isCanceled()

Returns true if this exchange was canceled.

Returns:boolean: true if this exchange was canceled.

isTCP	back to summary
private static boolean isTCP(HttpConnection connection)

nullBody	back to summary
pack-priv void nullBody(HttpResponse<T> resp, Throwable t)

onProtocolError back to summary

onProtocolError	back to summary
pack-priv abstract void onProtocolError(IOException cause) Invoked whenever there is a (HTTP) protocol error when dealing with the response from the server. The implementations of `ExchangeImpl` are then expected to take necessary action that is expected by the corresponding specifications whenever a protocol error happens. For example, in HTTP/1.1, such protocol error would result in the connection being closed. Parameters cause:IOException The cause of the protocol violation

pack-priv abstract void onProtocolError(IOException cause)

Invoked whenever there is a (HTTP) protocol error when dealing with the response from the server. The implementations of ExchangeImpl are then expected to take necessary action that is expected by the corresponding specifications whenever a protocol error happens. For example, in HTTP/1.1, such protocol error would result in the connection being closed.

Parameters

cause:IOException: The cause of the protocol violation

readBodyAsync	back to summary
pack-priv abstract CompletableFuture<T> readBodyAsync(HttpResponse.BodyHandler<T> handler, boolean returnConnectionToPool, Executor executor)

released	back to summary
pack-priv abstract void released() Called when the exchange is released, so that cleanup actions may be performed - such as deregistering callbacks. Typically released is called during upgrade, when an HTTP/2 stream takes over from an Http1Exchange, or when a new exchange is created during a multi exchange before the final response body was received.

sendBodyAsync	back to summary
pack-priv abstract CompletableFuture<ExchangeImpl<T>> sendBodyAsync() Sends a request body, after request headers have been sent.

sendHeadersAsync	back to summary
pack-priv abstract CompletableFuture<ExchangeImpl<T>> sendHeadersAsync()

setExpectTimeoutRaised	back to summary
pack-priv final void setExpectTimeoutRaised()

upgraded	back to summary
pack-priv void upgraded()

pack-priv abstract Class ExchangeImpl<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail