Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	Http3PushPromiseStream.Http3PushStreamResponseSubscriber<U>
private class	Http3PushPromiseStream.PushRespHeadersConsumer

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	closed
private final Http3Connection	connection
private String	dbgTag
private final Logger	debug Hides jdk.internal.net.http.ExchangeImpl.debug.
private final AtomicReference<Throwable>	errorRef
private final H3FrameOrderVerifier	frameOrderVerifier
private final FramesDecoder	framesDecoder
private final Http3ExchangeImpl<T>	parent
pack-priv volatile HttpResponse.BodySubscriber<T>	pendingResponseSubscriber
private final CompletableFuture<Response>	pushCF
private final HttpResponse.BodyHandler<T>	pushHandler
private final long	pushId
private final Http3PushManager	pushManager
private final Decoder	qpackDecoder
private final QuicStreamReader	reader
private final SequentialScheduler	readScheduler
private final HeaderFrameReader	respHeaderFrameReader
private final HttpHeadersBuilder	respHeadersBuilder
private final Http3PushPromiseStream<T>.PushRespHeadersConsumer	respHeadersConsumer
pack-priv volatile Response	response
pack-priv volatile CompletableFuture<T>	responseBodyCF
private final CompletableFuture<HttpResponse<T>>	responseCF
pack-priv volatile int	responseCode
pack-priv volatile boolean	responseReceived
pack-priv volatile HttpResponse.BodySubscriber<T>	responseSubscriber
private final ReentrantLock	stateLock
pack-priv volatile boolean	stopRequested
private final QuicReceiverStream	stream
pack-priv final SubscriptionBase	userSubscription

Inherited from jdk.internal.net.http.Http3Stream:: responseData

Constructor Summary

Access	Constructor and Description
pack-priv	Http3PushPromiseStream(Exchange<T> exchange, final Http3Connection connection, final Http3PushManager pushManager, final QuicReceiverStream stream, final CompletableFuture<HttpResponse<T>> responseCF, final HttpResponse.BodyHandler<T> pushHandler, Http3ExchangeImpl<T> parent, long pushId)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cancel() Implements abstract jdk.internal.net.http.ExchangeImpl.cancel. Cancels a request.
pack-priv void	cancel(IOException cause) Implements abstract jdk.internal.net.http.ExchangeImpl.cancel. Cancels a request with a cause.
pack-priv void	cancelImpl(Throwable e, Http3Error error) Implements abstract jdk.internal.net.http.Http3Stream.cancelImpl. Cancel the stream exchange on error
pack-priv void	close()
pack-priv void	completed() Implements abstract jdk.internal.net.http.ExchangeImpl.completed. Called when the exchange is completed, so that cleanup actions may be performed - such as deregistering callbacks.
pack-priv void	completeResponse(Response r) Implements abstract jdk.internal.net.http.Http3Stream.completeResponse. Called at the end of `handleResponse`, to propagate the response to the multi exchange.
pack-priv void	completeResponseExceptionally(Throwable t) same as above but for errors
pack-priv HttpQuicConnection	connection() Implements abstract jdk.internal.net.http.ExchangeImpl.connection. Returns the `HttpConnection` instance to which this exchange is assigned.
pack-priv void	connectionError(Throwable throwable, long errorCode, String errMsg) Implements abstract jdk.internal.net.http.Http3Stream.connectionError. Notify of a connection error.
pack-priv Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<T>	createResponseSubscriber(HttpResponse.BodyHandler<T> handler, HttpResponse.ResponseInfo response) Overrides jdk.internal.net.http.ExchangeImpl.createResponseSubscriber. Creates and wraps an `HttpResponse.BodySubscriber` from a `HttpResponse.BodyHandler` for the given `ResponseInfo`.
pack-priv String	dbgTag()
pack-priv Throwable	getCancelCause() Implements abstract jdk.internal.net.http.ExchangeImpl.getCancelCause. Returns the cause for which this exchange was canceled, if available.
pack-priv HttpResponse.BodyHandler<T>	getPushHandler()
pack-priv CompletableFuture<Response>	getResponseAsync(Executor executor) Implements abstract jdk.internal.net.http.ExchangeImpl.getResponseAsync. Gets the response headers.
protected void	handleResponse()
pack-priv CompletableFuture<Void>	ignoreBody() Implements abstract jdk.internal.net.http.ExchangeImpl.ignoreBody. Ignore/consume the body.
pack-priv boolean	isCanceled() Implements abstract jdk.internal.net.http.ExchangeImpl.isCanceled. Returns true if this exchange was canceled.
pack-priv Response	newResponse(HttpHeaders responseHeaders, int responseCode) Implements abstract jdk.internal.net.http.Http3Stream.newResponse. Called to create a new Response object for the newly receive response headers and response status code.
pack-priv void	nullBody(HttpResponse<T> resp, Throwable t) Overrides jdk.internal.net.http.ExchangeImpl.nullBody.
pack-priv void	onPollException(QuicStreamReader reader, IOException io) Implements abstract jdk.internal.net.http.Http3Stream.onPollException. Called when an exception is thrown by `reader::poll` when called from `processQuicData`.
pack-priv void	onProtocolError(IOException cause) Implements abstract jdk.internal.net.http.ExchangeImpl.onProtocolError. Invoked whenever there is a (HTTP) protocol error when dealing with the response from the server.
pack-priv void	onReaderReset() Implements abstract jdk.internal.net.http.Http3Stream.onReaderReset. Called when `processQuicData` detects that the reader has been reset.
pack-priv void	onSubscriptionError(Throwable t)
private void	processQuicData()
pack-priv long	pushId()
pack-priv void	pushResponseData(ConcurrentLinkedQueue<List<ByteBuffer>> responseData) Implements abstract jdk.internal.net.http.Http3Stream.pushResponseData. Push response data to the response body subscriber if allowed by the subscription state.
pack-priv CompletableFuture<T>	readBodyAsync(HttpResponse.BodyHandler<T> handler, boolean returnConnectionToPool, Executor executor) Implements abstract jdk.internal.net.http.ExchangeImpl.readBodyAsync.
pack-priv void	receiveHeaders(HeadersFrame headers, List<ByteBuffer> payload) Implements abstract jdk.internal.net.http.Http3Stream.receiveHeaders. Called when new payload data is received by `processQuicData` for a given header frame.
pack-priv void	receivePushPromiseFrame(PushPromiseFrame ppf, List<ByteBuffer> payload) Implements abstract jdk.internal.net.http.Http3Stream.receivePushPromiseFrame. Called when new payload data is received by `processQuicData` for a given push promise frame.
pack-priv CompletableFuture<T>	receiveResponseBody(HttpResponse.BodySubscriber<T> bodySubscriber, Executor executor)
private void	registerResponseSubscriber(Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<?> subscriber)
pack-priv void	released() Implements abstract jdk.internal.net.http.ExchangeImpl.released. Called when the exchange is released, so that cleanup actions may be performed - such as deregistering callbacks.
pack-priv CompletableFuture<HttpResponse<T>>	responseCF()
pack-priv void	responseReceived()
private void	responseReceived0()
pack-priv CompletableFuture<ExchangeImpl<T>>	sendBodyAsync() Implements abstract jdk.internal.net.http.ExchangeImpl.sendBodyAsync. Sends a request body, after request headers have been sent.
pack-priv CompletableFuture<ExchangeImpl<T>>	sendHeadersAsync() Implements abstract jdk.internal.net.http.ExchangeImpl.sendHeadersAsync.
pack-priv void	start()
pack-priv long	streamId() Implements abstract jdk.internal.net.http.Http3Stream.streamId. Returns the Quic stream id for this exchange (request/response or push response).
private void	unregisterResponseSubscriber(Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<?> subscriber)

Inherited from jdk.internal.net.http.Http3Stream:: checkInterimResponseCountExceeded connectionError handleResponse processQuicData readingPaused receivedQuicBytes switchReadingPaused

Field Detail

closed	back to summary
pack-priv volatile boolean closed

connection	back to summary
private final Http3Connection connection

dbgTag	back to summary
private String dbgTag

debug	back to summary
private final Logger debug Hides jdk.internal.net.http.ExchangeImpl.debug.

errorRef	back to summary
private final AtomicReference<Throwable> errorRef

frameOrderVerifier	back to summary
private final H3FrameOrderVerifier frameOrderVerifier

framesDecoder	back to summary
private final FramesDecoder framesDecoder

parent	back to summary
private final Http3ExchangeImpl<T> parent

pendingResponseSubscriber	back to summary
pack-priv volatile HttpResponse.BodySubscriber<T> pendingResponseSubscriber

pushCF	back to summary
private final CompletableFuture<Response> pushCF

pushHandler	back to summary
private final HttpResponse.BodyHandler<T> pushHandler

pushId	back to summary
private final long pushId

pushManager	back to summary
private final Http3PushManager pushManager

qpackDecoder	back to summary
private final Decoder qpackDecoder

reader	back to summary
private final QuicStreamReader reader

readScheduler	back to summary
private final SequentialScheduler readScheduler

respHeaderFrameReader	back to summary
private final HeaderFrameReader respHeaderFrameReader

respHeadersBuilder	back to summary
private final HttpHeadersBuilder respHeadersBuilder

respHeadersConsumer	back to summary
private final Http3PushPromiseStream<T>.PushRespHeadersConsumer respHeadersConsumer

response	back to summary
pack-priv volatile Response response

responseBodyCF	back to summary
pack-priv volatile CompletableFuture<T> responseBodyCF

responseCF	back to summary
private final CompletableFuture<HttpResponse<T>> responseCF

responseCode	back to summary
pack-priv volatile int responseCode

responseReceived	back to summary
pack-priv volatile boolean responseReceived

responseSubscriber	back to summary
pack-priv volatile HttpResponse.BodySubscriber<T> responseSubscriber

stateLock	back to summary
private final ReentrantLock stateLock

stopRequested	back to summary
pack-priv volatile boolean stopRequested

stream	back to summary
private final QuicReceiverStream stream

userSubscription	back to summary
pack-priv final SubscriptionBase userSubscription

Constructor Detail

Http3PushPromiseStream	back to summary
pack-priv Http3PushPromiseStream(Exchange<T> exchange, final Http3Connection connection, final Http3PushManager pushManager, final QuicReceiverStream stream, final CompletableFuture<HttpResponse<T>> responseCF, final HttpResponse.BodyHandler<T> pushHandler, Http3ExchangeImpl<T> parent, long pushId)

Method Detail

cancel	back to summary
pack-priv void cancel() Implements abstract jdk.internal.net.http.ExchangeImpl.cancel. Doc from jdk.internal.net.http.ExchangeImpl.cancel. Cancels a request. Not currently exposed through API. Annotations @Override

cancel

back to summary

pack-priv void cancel()

Implements abstract jdk.internal.net.http.ExchangeImpl.cancel.

Doc from jdk.internal.net.http.ExchangeImpl.cancel.

Cancels a request. Not currently exposed through API.

Annotations

@Override

cancel	back to summary
pack-priv void cancel(IOException cause) Implements abstract jdk.internal.net.http.ExchangeImpl.cancel. Doc from jdk.internal.net.http.ExchangeImpl.cancel. Cancels a request with a cause. Not currently exposed through API. Annotations @Override

cancel

back to summary

pack-priv void cancel(IOException cause)

Implements abstract jdk.internal.net.http.ExchangeImpl.cancel.

Doc from jdk.internal.net.http.ExchangeImpl.cancel.

Cancels a request with a cause. Not currently exposed through API.

Annotations

@Override

cancelImpl	back to summary
pack-priv void cancelImpl(Throwable e, Http3Error error) Implements abstract jdk.internal.net.http.Http3Stream.cancelImpl. Doc from jdk.internal.net.http.Http3Stream.cancelImpl. Cancel the stream exchange on error Annotations @Override

cancelImpl

back to summary

pack-priv void cancelImpl(Throwable e, Http3Error error)

Implements abstract jdk.internal.net.http.Http3Stream.cancelImpl.

Doc from jdk.internal.net.http.Http3Stream.cancelImpl.

Cancel the stream exchange on error

Annotations

@Override

close	back to summary
pack-priv void close()

completed	back to summary
pack-priv void completed() Implements abstract jdk.internal.net.http.ExchangeImpl.completed. Doc from jdk.internal.net.http.ExchangeImpl.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). Annotations @Override

completed

back to summary

pack-priv void completed()

Implements abstract jdk.internal.net.http.ExchangeImpl.completed.

Doc from jdk.internal.net.http.ExchangeImpl.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).

Annotations

@Override

completeResponse back to summary

completeResponse	back to summary
pack-priv void completeResponse(Response r) Implements abstract jdk.internal.net.http.Http3Stream.completeResponse. Doc from jdk.internal.net.http.Http3Stream.completeResponse. Called at the end of `handleResponse`, to propagate the response to the multi exchange.

pack-priv void completeResponse(Response r)

Implements abstract jdk.internal.net.http.Http3Stream.completeResponse.

Doc from jdk.internal.net.http.Http3Stream.completeResponse.

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

completeResponseExceptionally	back to summary
pack-priv void completeResponseExceptionally(Throwable t) same as above but for errors

connection back to summary

connection	back to summary
pack-priv HttpQuicConnection connection() Implements abstract jdk.internal.net.http.ExchangeImpl.connection. Doc from jdk.internal.net.http.ExchangeImpl.connection. Returns the `HttpConnection` instance to which this exchange is assigned. Annotations @Override

pack-priv HttpQuicConnection connection()

Implements abstract jdk.internal.net.http.ExchangeImpl.connection.

Doc from jdk.internal.net.http.ExchangeImpl.connection.

Returns the HttpConnection instance to which this exchange is assigned.

Annotations

@Override

connectionError	back to summary
pack-priv void connectionError(Throwable throwable, long errorCode, String errMsg) Implements abstract jdk.internal.net.http.Http3Stream.connectionError. Doc from jdk.internal.net.http.Http3Stream.connectionError. 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

back to summary

pack-priv void connectionError(Throwable throwable, long errorCode, String errMsg)

Implements abstract jdk.internal.net.http.Http3Stream.connectionError.

Doc from jdk.internal.net.http.Http3Stream.connectionError.

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

createResponseSubscriber back to summary

createResponseSubscriber	back to summary
pack-priv Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<T> createResponseSubscriber(HttpResponse.BodyHandler<T> handler, HttpResponse.ResponseInfo response) Overrides jdk.internal.net.http.ExchangeImpl.createResponseSubscriber. Doc from jdk.internal.net.http.ExchangeImpl.createResponseSubscriber. 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.

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

Overrides jdk.internal.net.http.ExchangeImpl.createResponseSubscriber.

Doc from jdk.internal.net.http.ExchangeImpl.createResponseSubscriber.

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.

dbgTag	back to summary
pack-priv String dbgTag()

getCancelCause	back to summary
pack-priv Throwable getCancelCause() Implements abstract jdk.internal.net.http.ExchangeImpl.getCancelCause. Doc from jdk.internal.net.http.ExchangeImpl.getCancelCause. Returns the cause for which this exchange was canceled, if available. Annotations @Override

getCancelCause

back to summary

pack-priv Throwable getCancelCause()

Implements abstract jdk.internal.net.http.ExchangeImpl.getCancelCause.

Doc from jdk.internal.net.http.ExchangeImpl.getCancelCause.

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

Annotations

@Override

getPushHandler	back to summary
pack-priv HttpResponse.BodyHandler<T> getPushHandler()

getResponseAsync	back to summary
pack-priv CompletableFuture<Response> getResponseAsync(Executor executor) Implements abstract jdk.internal.net.http.ExchangeImpl.getResponseAsync. Doc from jdk.internal.net.http.ExchangeImpl.getResponseAsync. Gets the response headers. Completes before body is read. Annotations @Override

getResponseAsync

back to summary

pack-priv CompletableFuture<Response> getResponseAsync(Executor executor)

Implements abstract jdk.internal.net.http.ExchangeImpl.getResponseAsync.

Doc from jdk.internal.net.http.ExchangeImpl.getResponseAsync.

Gets the response headers. Completes before body is read.

Annotations

@Override

handleResponse	back to summary
protected void handleResponse()

ignoreBody	back to summary
pack-priv CompletableFuture<Void> ignoreBody() Implements abstract jdk.internal.net.http.ExchangeImpl.ignoreBody. Doc from jdk.internal.net.http.ExchangeImpl.ignoreBody. Ignore/consume the body. Annotations @Override

ignoreBody

back to summary

pack-priv CompletableFuture<Void> ignoreBody()

Implements abstract jdk.internal.net.http.ExchangeImpl.ignoreBody.

Doc from jdk.internal.net.http.ExchangeImpl.ignoreBody.

Ignore/consume the body.

Annotations

@Override

isCanceled

back to summary

pack-priv boolean isCanceled()

Implements abstract jdk.internal.net.http.ExchangeImpl.isCanceled.

Doc from jdk.internal.net.http.ExchangeImpl.isCanceled.

Returns true if this exchange was canceled.

Annotations

@Override

newResponse back to summary

pack-priv Response newResponse(HttpHeaders responseHeaders, int responseCode)

Implements abstract jdk.internal.net.http.Http3Stream.newResponse.

Doc from jdk.internal.net.http.Http3Stream.newResponse.

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.

Annotations

@Override

nullBody	back to summary
pack-priv void nullBody(HttpResponse<T> resp, Throwable t) Overrides jdk.internal.net.http.ExchangeImpl.nullBody.

onPollException back to summary

pack-priv void onPollException(QuicStreamReader reader, IOException io)

Implements abstract jdk.internal.net.http.Http3Stream.onPollException.

Doc from jdk.internal.net.http.Http3Stream.onPollException.

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

Annotations

@Override

onProtocolError back to summary

pack-priv void onProtocolError(IOException cause)

Implements abstract jdk.internal.net.http.ExchangeImpl.onProtocolError.

Doc from jdk.internal.net.http.ExchangeImpl.onProtocolError.

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.

Annotations

@Override

onReaderReset back to summary

pack-priv void onReaderReset()

Implements abstract jdk.internal.net.http.Http3Stream.onReaderReset.

Doc from jdk.internal.net.http.Http3Stream.onReaderReset.

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.

Annotations

@Override

onSubscriptionError	back to summary
pack-priv void onSubscriptionError(Throwable t)

processQuicData	back to summary
private void processQuicData()

pushId	back to summary
pack-priv long pushId()

pushResponseData

back to summary

pack-priv void pushResponseData(ConcurrentLinkedQueue<List<ByteBuffer>> responseData)

Implements abstract jdk.internal.net.http.Http3Stream.pushResponseData.

Doc from jdk.internal.net.http.Http3Stream.pushResponseData.

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

readBodyAsync

back to summary

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

Implements abstract jdk.internal.net.http.ExchangeImpl.readBodyAsync.

Annotations

@Override

receiveHeaders back to summary

pack-priv void receiveHeaders(HeadersFrame headers, List<ByteBuffer> payload) throws IOException

Implements abstract jdk.internal.net.http.Http3Stream.receiveHeaders.

Doc from jdk.internal.net.http.Http3Stream.receiveHeaders.

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

Any exception thrown here will be rethrown by processQuicData

Exceptions

IOException:: if an error is detected

receivePushPromiseFrame back to summary

pack-priv void receivePushPromiseFrame(PushPromiseFrame ppf, List<ByteBuffer> payload) throws IOException

Implements abstract jdk.internal.net.http.Http3Stream.receivePushPromiseFrame.

Doc from jdk.internal.net.http.Http3Stream.receivePushPromiseFrame.

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

Any exception thrown here will be rethrown by processQuicData

Annotations

@Override

Exceptions

IOException:: if an error is detected

receiveResponseBody	back to summary
pack-priv CompletableFuture<T> receiveResponseBody(HttpResponse.BodySubscriber<T> bodySubscriber, Executor executor)

registerResponseSubscriber	back to summary
private void registerResponseSubscriber(Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<?> subscriber)

released

back to summary

pack-priv void released()

Implements abstract jdk.internal.net.http.ExchangeImpl.released.

Doc from jdk.internal.net.http.ExchangeImpl.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.

Annotations

@Override

responseCF	back to summary
pack-priv CompletableFuture<HttpResponse<T>> responseCF()

responseReceived	back to summary
pack-priv void responseReceived()

responseReceived0	back to summary
private void responseReceived0()

sendBodyAsync

back to summary

pack-priv CompletableFuture<ExchangeImpl<T>> sendBodyAsync()

Implements abstract jdk.internal.net.http.ExchangeImpl.sendBodyAsync.

Doc from jdk.internal.net.http.ExchangeImpl.sendBodyAsync.

Sends a request body, after request headers have been sent.

Annotations

@Override

sendHeadersAsync

back to summary

pack-priv CompletableFuture<ExchangeImpl<T>> sendHeadersAsync()

Implements abstract jdk.internal.net.http.ExchangeImpl.sendHeadersAsync.

Annotations

@Override

start	back to summary
pack-priv void start()

streamId

back to summary

pack-priv long streamId()

Implements abstract jdk.internal.net.http.Http3Stream.streamId.

Doc from jdk.internal.net.http.Http3Stream.streamId.

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

Annotations

@Override

unregisterResponseSubscriber	back to summary
private void unregisterResponseSubscriber(Http3PushPromiseStream<T>.Http3PushStreamResponseSubscriber<?> subscriber)

jdk.internal.net.http back to summary

pack-priv final Class Http3PushPromiseStream.Http3PushStreamResponseSubscriber<U>

Class Inheritance

extends HttpBodySubscriberWrapper<U>

java.lang.Object
jdk.internal.net.http.common.HttpBodySubscriberWrapper
jdk.internal.net.http.Http3PushPromiseStream.Http3PushStreamResponseSubscriber

Field Summary

Inherited from jdk.internal.net.http.common.HttpBodySubscriberWrapper:: COMPARE_BY_ID NOP

Constructor Summary

Access	Constructor and Description
pack-priv	Http3PushStreamResponseSubscriber(HttpResponse.BodySubscriber<U> subscriber)

Method Summary

Modifier and Type	Method and Description
protected void	register() Overrides jdk.internal.net.http.common.HttpBodySubscriberWrapper.register. This method can be implemented by subclasses to perform registration actions.
protected void	unregister() Overrides jdk.internal.net.http.common.HttpBodySubscriberWrapper.unregister. This method can be implemented by subclasses to perform unregistration actions.

Inherited from jdk.internal.net.http.common.HttpBodySubscriberWrapper:: cancelled complete completed getBody logComplete needsExecutor onCancel onComplete onError onNext onSubscribe onTermination registered subscribed tryRegister tryUnregister unregistered

Constructor Detail

Http3PushStreamResponseSubscriber	back to summary
pack-priv Http3PushStreamResponseSubscriber(HttpResponse.BodySubscriber<U> subscriber)

Method Detail

back to summary

protected void register()

Overrides jdk.internal.net.http.common.HttpBodySubscriberWrapper.register.

Doc from jdk.internal.net.http.common.HttpBodySubscriberWrapper.register.

This method can be implemented by subclasses to perform registration actions. It will not be called if already registered or unregistered.

Annotations

@Override

unregister

back to summary

protected void unregister()

Overrides jdk.internal.net.http.common.HttpBodySubscriberWrapper.unregister.

Doc from jdk.internal.net.http.common.HttpBodySubscriberWrapper.unregister.

This method can be implemented by subclasses to perform unregistration actions. It will not be called if not already registered, or already unregistered.

Annotations

@Override

jdk.internal.net.http back to summary

private final Class Http3PushPromiseStream.PushRespHeadersConsumer

Class Inheritance

extends Http3Stream<T>.StreamHeadersConsumer

java.lang.Object
jdk.internal.net.http.common.ValidatingHeadersConsumer
jdk.internal.net.http.Http3Stream.StreamHeadersConsumer
jdk.internal.net.http.Http3PushPromiseStream.PushRespHeadersConsumer

Constructor Summary

Access	Constructor and Description
public	PushRespHeadersConsumer()

Method Summary

Modifier and Type	Method and Description
protected String	formatMessage(String message, String header) Overrides jdk.internal.net.http.common.ValidatingHeadersConsumer.formatMessage.
pack-priv String	headerFieldType() Overrides jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.headerFieldType.
pack-priv HeaderFrameReader	headerFrameReader() Implements abstract jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.headerFrameReader.
pack-priv HttpHeadersBuilder	headersBuilder() Implements abstract jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.headersBuilder.
pack-priv void	headersCompleted() Implements abstract jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.headersCompleted.
pack-priv Decoder	qpackDecoder() Implements abstract jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.qpackDecoder.
pack-priv void	resetDone() Implements abstract jdk.internal.net.http.Http3Stream.StreamHeadersConsumer.resetDone.
public long	streamId() Implements jdk.internal.net.http.qpack.DecodingCallback.streamId. Returns request/response stream id or push stream id associated with a decoding callback.