OpenJDK 27 · jdk.internal.net.http.http3.streams.UniStreamPair

Modifier and Type	Class and Description
public static interface	UniStreamPair.StreamErrorHandler

Modifier and Type	Field and Description
pack-priv final Logger	debug
pack-priv final UniStreamPair.StreamErrorHandler	errorHandler
private volatile CompletableFuture<QuicSenderStream>	localSenderStreamCF
private final Http3Streams.StreamType	localStreamType
private volatile QuicStreamWriter	localWriter
private final SequentialScheduler	localWriteScheduler
private final ReentrantLock	lock
pack-priv volatile QuicStreamReader	peerReader
pack-priv final SequentialScheduler	peerReadScheduler
private final CompletableFuture<QuicReceiverStream>	peerReceiverStreamCF
private final QuicConnection	quicConnection
private final Consumer<ByteBuffer>	receiver
private final Http3Streams.StreamType	remoteStreamType
private final CompletableFuture<QuicStreamReader>	streamReaderCF
private final CompletableFuture<QuicStreamWriter>	streamWriterCF

Access	Constructor and Description
public	UniStreamPair(Http3Streams.StreamType the HTTP/3 stream type streamType, QuicConnection the underlying Quic connection quicConnection, Consumer<ByteBuffer> the receiver callback receiver, Runnable the writer loop writerLoop, UniStreamPair.StreamErrorHandler the error handler invoked in case of read errors errorHandler, Logger the debug logger logger) Creates a new `UniStreamPair` for the given HTTP/3 `streamType`.
pack-priv	UniStreamPair(Http3Streams.StreamType the HTTP/3 stream type streamType, QuicConnection the underlying Quic connection quicConnection, Consumer<ByteBuffer> the receiver callback receiver, UniStreamPair.StreamErrorHandler the error handler invoked in case of read or write errors errorHandler, Logger logger) A constructor used by the `QueuingStreamPair` subclass
private	UniStreamPair(Http3Streams.StreamType localStreamType, Http3Streams.StreamType remoteStreamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, Optional<Runnable> writerLoop, UniStreamPair.StreamErrorHandler errorHandler, Logger logger)

Method Summary

Modifier and Type	Method and Description
private QuicStreamReader	Returns: the peer control stream reader connectReceiverStream(QuicReceiverStream the peer control stream peerControlStream) Connects the peer control stream reader and schedules the receiving of the peer settings from the given `peerControlStream`.
public CompletableFuture<QuicReceiverStream>	Returns: a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream futureReceiverStream() Returns a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream.
public final CompletableFuture<QuicStreamReader>	Returns: a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream futureReceiverStreamReader() Returns a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream.
public CompletableFuture<QuicSenderStream>	Returns: a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue futureSenderStream() Returns a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue.
public final CompletableFuture<QuicStreamWriter>	Returns: a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue futureSenderStreamWriter() Returns a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue.
private static Http3Streams.StreamType	local(Http3Streams.StreamType localStreamType)
private CompletableFuture<QuicSenderStream>	Returns: a completable future that will be completed with the local sender stream localSenderStream() Creates the local sender stream and queues the stream type code in its writer queue.
public final Http3Streams.StreamType	Returns: the HTTP/3 stream type of the sender part of the stream pair localStreamType() Returns the HTTP/3 stream type of the sender part of the stream pair.
public QuicStreamWriter	Returns: the writer connected to the sender part of this stream or `null` if no writer is connected yet localWriter() Returns the writer connected to the sender part of this stream or `null` if no writer is connected yet.
pack-priv void	localWriterLoop() This method is overridden by `QueuingStreamPair` to implement a writer loop for this stream.
public SequentialScheduler	Returns: the scheduler for the local writer loop localWriteScheduler() Returns the scheduler for the local writer loop.
private QuicSenderStream	Returns: the given `stream` openLocalStream(QuicSenderStream a new local unidirectional stream stream, int the code to queue up on the stream writer queue code) Queues the given HTTP/3 stream type code on the given local unidirectional stream writer queue.
private void	peerReaderLoop()
private void	processPeerControlBytes(ByteBuffer the bytes received buffer) This method is called to process bytes received on the peer control stream.
private static Http3Streams.StreamType	remote(Http3Streams.StreamType localStreamType)
public final Http3Streams.StreamType	Returns: the HTTP/3 stream type of the receiver part of the stream pair remoteStreamType() Returns the HTTP/3 stream type of the receiver part of the stream pair.
private CompletableFuture<QuicStreamReader>	Returns: a completable future that will be completed with the `QuicStreamReader` allowing to read from the remote control stream. startReceiving() Schedules the receiving of server settings
private CompletableFuture<QuicStreamWriter>	Returns: a completable future that will be completed with the `QuicStreamWriter` allowing to write to the local control stream startSending() Schedules sending of client settings.
public void	stopSchedulers() Stops schedulers.
pack-priv QuicStreamWriter	Returns: a writer that can be safely used. wrap(QuicStreamWriter the downstream writer writer) Used by subclasses to redirect queuing of data to the subclass queue.

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

Field Detail

debug	back to summary
pack-priv final Logger debug

errorHandler	back to summary
pack-priv final UniStreamPair.StreamErrorHandler errorHandler

localSenderStreamCF	back to summary
private volatile CompletableFuture<QuicSenderStream> localSenderStreamCF

localStreamType	back to summary
private final Http3Streams.StreamType localStreamType

localWriter	back to summary
private volatile QuicStreamWriter localWriter

localWriteScheduler	back to summary
private final SequentialScheduler localWriteScheduler

lock	back to summary
private final ReentrantLock lock

peerReader	back to summary
pack-priv volatile QuicStreamReader peerReader

peerReadScheduler	back to summary
pack-priv final SequentialScheduler peerReadScheduler

peerReceiverStreamCF	back to summary
private final CompletableFuture<QuicReceiverStream> peerReceiverStreamCF

quicConnection	back to summary
private final QuicConnection quicConnection

receiver	back to summary
private final Consumer<ByteBuffer> receiver

remoteStreamType	back to summary
private final Http3Streams.StreamType remoteStreamType

streamReaderCF	back to summary
private final CompletableFuture<QuicStreamReader> streamReaderCF

streamWriterCF	back to summary
private final CompletableFuture<QuicStreamWriter> streamWriterCF

Constructor Detail

UniStreamPair back to summary

UniStreamPair	back to summary
public UniStreamPair(Http3Streams.StreamType streamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, Runnable writerLoop, UniStreamPair.StreamErrorHandler errorHandler, Logger logger) Creates a new `UniStreamPair` for the given HTTP/3 `streamType`. Valid values for `streamType` are `StreamType#CONTROL`, `StreamType#QPACK_ENCODER`, and `StreamType#QPACK_DECODER`. This class implements a read loop that will call the given `receiver` whenever a `ByteBuffer` is received. Writing to the sender part can be done by interacting directly with the writer. If the writer is blocked due to flow control, and becomes unblocked again, the `writeLoop` is invoked. The `QueuingStreamPair` subclass provides a convenient implementation of a `writeLoop` based on an unbounded queue of `ByteBuffer`. Parameters streamType:Http3Streams.StreamType the HTTP/3 stream type quicConnection:QuicConnection the underlying Quic connection receiver:Consumer<ByteBuffer> the receiver callback writerLoop:Runnable the writer loop errorHandler:UniStreamPair.StreamErrorHandler the error handler invoked in case of read errors logger:Logger the debug logger

public UniStreamPair(Http3Streams.StreamType streamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, Runnable writerLoop, UniStreamPair.StreamErrorHandler errorHandler, Logger logger)

Creates a new UniStreamPair for the given HTTP/3 streamType. Valid values for streamType are StreamType#CONTROL, StreamType#QPACK_ENCODER, and StreamType#QPACK_DECODER.

This class implements a read loop that will call the given receiver whenever a ByteBuffer is received.

Writing to the sender part can be done by interacting directly with the writer. If the writer is blocked due to flow control, and becomes unblocked again, the writeLoop is invoked. The QueuingStreamPair subclass provides a convenient implementation of a writeLoop based on an unbounded queue of ByteBuffer.

Parameters

streamType:Http3Streams.StreamType: the HTTP/3 stream type
quicConnection:QuicConnection: the underlying Quic connection
receiver:Consumer<ByteBuffer>: the receiver callback
writerLoop:Runnable: the writer loop
errorHandler:UniStreamPair.StreamErrorHandler: the error handler invoked in case of read errors
logger:Logger: the debug logger

UniStreamPair back to summary

UniStreamPair	back to summary
pack-priv UniStreamPair(Http3Streams.StreamType streamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, UniStreamPair.StreamErrorHandler errorHandler, Logger logger) A constructor used by the `QueuingStreamPair` subclass Parameters streamType:Http3Streams.StreamType the HTTP/3 stream type quicConnection:QuicConnection the underlying Quic connection receiver:Consumer<ByteBuffer> the receiver callback errorHandler:UniStreamPair.StreamErrorHandler the error handler invoked in case of read or write errors

pack-priv UniStreamPair(Http3Streams.StreamType streamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, UniStreamPair.StreamErrorHandler errorHandler, Logger logger)

A constructor used by the QueuingStreamPair subclass

Parameters

streamType:Http3Streams.StreamType: the HTTP/3 stream type
quicConnection:QuicConnection: the underlying Quic connection
receiver:Consumer<ByteBuffer>: the receiver callback
errorHandler:UniStreamPair.StreamErrorHandler: the error handler invoked in case of read or write errors

UniStreamPair	back to summary
private UniStreamPair(Http3Streams.StreamType localStreamType, Http3Streams.StreamType remoteStreamType, QuicConnection quicConnection, Consumer<ByteBuffer> receiver, Optional<Runnable> writerLoop, UniStreamPair.StreamErrorHandler errorHandler, Logger logger)

Method Detail

connectReceiverStream back to summary

connectReceiverStream	back to summary
private QuicStreamReader connectReceiverStream(QuicReceiverStream peerControlStream) Connects the peer control stream reader and schedules the receiving of the peer settings from the given `peerControlStream`. Parameters peerControlStream:QuicReceiverStream the peer control stream Returns:QuicStreamReader the peer control stream reader

private QuicStreamReader connectReceiverStream(QuicReceiverStream peerControlStream)

Connects the peer control stream reader and schedules the receiving of the peer settings from the given peerControlStream.

Parameters

peerControlStream:QuicReceiverStream: the peer control stream

Returns:QuicStreamReader

the peer control stream reader

futureReceiverStream	back to summary
public CompletableFuture<QuicReceiverStream> futureReceiverStream() Returns a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream. Returns:CompletableFuture<QuicReceiverStream> a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream

futureReceiverStream

back to summary

public CompletableFuture<QuicReceiverStream> futureReceiverStream()

Returns a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream.

Returns:CompletableFuture<QuicReceiverStream>: a completable future that will be completed with the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream

futureReceiverStreamReader	back to summary
public final CompletableFuture<QuicStreamReader> futureReceiverStreamReader() Returns a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream. Returns:CompletableFuture<QuicStreamReader> a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream

futureReceiverStreamReader

back to summary

public final CompletableFuture<QuicStreamReader> futureReceiverStreamReader()

Returns a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream.

Returns:CompletableFuture<QuicStreamReader>: a completable future that will be completed with a reader connected to the receiver part of this stream pair after the remote HTTP/3 stream type has been read off the remote initiated stream

futureSenderStream	back to summary
public CompletableFuture<QuicSenderStream> futureSenderStream() Returns a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue. Returns:CompletableFuture<QuicSenderStream> a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue

futureSenderStream

back to summary

public CompletableFuture<QuicSenderStream> futureSenderStream()

Returns a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue.

Returns:CompletableFuture<QuicSenderStream>: a completable future that will be completed with the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue

futureSenderStreamWriter	back to summary
public final CompletableFuture<QuicStreamWriter> futureSenderStreamWriter() Returns a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue. Returns:CompletableFuture<QuicStreamWriter> a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue

futureSenderStreamWriter

back to summary

public final CompletableFuture<QuicStreamWriter> futureSenderStreamWriter()

Returns a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue.

Returns:CompletableFuture<QuicStreamWriter>: a completable future that will be completed with a writer connected to the sender part of this stream pair after the local HTTP/3 stream type has been queued for writing on the writing queue

local	back to summary
private static Http3Streams.StreamType local(Http3Streams.StreamType localStreamType)

localSenderStream	back to summary
private CompletableFuture<QuicSenderStream> localSenderStream() Creates the local sender stream and queues the stream type code in its writer queue. Returns:CompletableFuture<QuicSenderStream> a completable future that will be completed with the local sender stream

localSenderStream

back to summary

private CompletableFuture<QuicSenderStream> localSenderStream()

Creates the local sender stream and queues the stream type code in its writer queue.

Returns:CompletableFuture<QuicSenderStream>: a completable future that will be completed with the local sender stream

localStreamType	back to summary
public final Http3Streams.StreamType localStreamType() Returns the HTTP/3 stream type of the sender part of the stream pair. Returns:Http3Streams.StreamType the HTTP/3 stream type of the sender part of the stream pair

localStreamType

back to summary

public final Http3Streams.StreamType localStreamType()

Returns the HTTP/3 stream type of the sender part of the stream pair.

Returns:Http3Streams.StreamType: the HTTP/3 stream type of the sender part of the stream pair

localWriter back to summary

localWriter	back to summary
public QuicStreamWriter localWriter() Returns the writer connected to the sender part of this stream or `null` if no writer is connected yet. Returns:QuicStreamWriter the writer connected to the sender part of this stream or `null` if no writer is connected yet

public QuicStreamWriter localWriter()

Returns the writer connected to the sender part of this stream or null if no writer is connected yet.

Returns:QuicStreamWriter: the writer connected to the sender part of this stream or null if no writer is connected yet

localWriterLoop	back to summary
pack-priv void localWriterLoop() This method is overridden by `QueuingStreamPair` to implement a writer loop for this stream. It is only called when the concrete subclass is `QueuingStreamPair`.

localWriteScheduler	back to summary
public SequentialScheduler localWriteScheduler() Returns the scheduler for the local writer loop. Returns:SequentialScheduler the scheduler for the local writer loop

localWriteScheduler

back to summary

public SequentialScheduler localWriteScheduler()

Returns the scheduler for the local writer loop.

Returns:SequentialScheduler: the scheduler for the local writer loop

openLocalStream back to summary

openLocalStream	back to summary
private QuicSenderStream openLocalStream(QuicSenderStream stream, int code) Queues the given HTTP/3 stream type code on the given local unidirectional stream writer queue. Parameters stream:QuicSenderStream a new local unidirectional stream code:int the code to queue up on the stream writer queue Returns:QuicSenderStream the given `stream`

private QuicSenderStream openLocalStream(QuicSenderStream stream, int code)

Queues the given HTTP/3 stream type code on the given local unidirectional stream writer queue.

Parameters

stream:QuicSenderStream: a new local unidirectional stream
code:int: the code to queue up on the stream writer queue

Returns:QuicSenderStream

the given stream

peerReaderLoop	back to summary
private void peerReaderLoop()

processPeerControlBytes	back to summary
private void processPeerControlBytes(ByteBuffer buffer) This method is called to process bytes received on the peer control stream. Parameters buffer:ByteBuffer the bytes received

processPeerControlBytes

back to summary

private void processPeerControlBytes(ByteBuffer buffer)

This method is called to process bytes received on the peer control stream.

Parameters

buffer:ByteBuffer: the bytes received

remote	back to summary
private static Http3Streams.StreamType remote(Http3Streams.StreamType localStreamType)

remoteStreamType	back to summary
public final Http3Streams.StreamType remoteStreamType() Returns the HTTP/3 stream type of the receiver part of the stream pair. Returns:Http3Streams.StreamType the HTTP/3 stream type of the receiver part of the stream pair

remoteStreamType

back to summary

public final Http3Streams.StreamType remoteStreamType()

Returns the HTTP/3 stream type of the receiver part of the stream pair.

Returns:Http3Streams.StreamType: the HTTP/3 stream type of the receiver part of the stream pair

startReceiving back to summary

startReceiving	back to summary
private CompletableFuture<QuicStreamReader> startReceiving() Schedules the receiving of server settings Returns:CompletableFuture<QuicStreamReader> a completable future that will be completed with the `QuicStreamReader` allowing to read from the remote control stream.

private CompletableFuture<QuicStreamReader> startReceiving()

Schedules the receiving of server settings

Returns:CompletableFuture<QuicStreamReader>: a completable future that will be completed with the QuicStreamReader allowing to read from the remote control stream.

startSending back to summary

startSending	back to summary
private CompletableFuture<QuicStreamWriter> startSending() Schedules sending of client settings. Returns:CompletableFuture<QuicStreamWriter> a completable future that will be completed with the `QuicStreamWriter` allowing to write to the local control stream

private CompletableFuture<QuicStreamWriter> startSending()

Schedules sending of client settings.

Returns:CompletableFuture<QuicStreamWriter>: a completable future that will be completed with the QuicStreamWriter allowing to write to the local control stream

stopSchedulers	back to summary
public void stopSchedulers() Stops schedulers. Can be called when the connection is closed to stop the reading and writing loops.

wrap	back to summary
pack-priv QuicStreamWriter wrap(QuicStreamWriter writer) Used by subclasses to redirect queuing of data to the subclass queue. Parameters writer:QuicStreamWriter the downstream writer Returns:QuicStreamWriter a writer that can be safely used.

wrap

back to summary

pack-priv QuicStreamWriter wrap(QuicStreamWriter writer)

Used by subclasses to redirect queuing of data to the subclass queue.

Parameters

writer:QuicStreamWriter: the downstream writer

Returns:QuicStreamWriter

a writer that can be safely used.

public Class UniStreamPair

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface UniStreamPair.StreamErrorHandler

Method Summary

Method Detail