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

A class that reads VL integers from a QUIC stream.

After constructing an instance of this class, the application is can call readInt() to read one VL integer off the stream. When the read operation completes, the application can call readInt again, or call stop() to disconnect the reader.

Field Summary

Modifier and Type	Field and Description
private CompletableFuture<Long>	cf
private final Logger	debug
private final QuicStreamReader	reader
private final SequentialScheduler	scheduler
private final QuicReceiverStream	stream
private ByteBuffer	vlongBuf

Constructor Summary

Access	Constructor and Description
public	QuicStreamIntReader(QuicReceiverStream a receiver stream with no connected reader stream, Logger a logger debug) Creates a `QuicStreamIntReader` for the given stream.

Method Summary

Modifier and Type	Method and Description
private void	dispatch()
public synchronized CompletableFuture<Long>	Returns: a `CompletableFuture<Long>` that will be completed with the decoded number, or -1 if the stream is terminated before the complete number could be read, or an exception if the stream is reset or decoding fails. readInt() Starts a read operation to decode a single number.
public synchronized void	stop() Stops and disconnects this reader.

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

Field Detail

cf	back to summary
private CompletableFuture<Long> cf

debug	back to summary
private final Logger debug

reader	back to summary
private final QuicStreamReader reader

scheduler	back to summary
private final SequentialScheduler scheduler

stream	back to summary
private final QuicReceiverStream stream

vlongBuf	back to summary
private ByteBuffer vlongBuf

Constructor Detail

QuicStreamIntReader back to summary

QuicStreamIntReader	back to summary
public QuicStreamIntReader(QuicReceiverStream stream, Logger debug) Creates a `QuicStreamIntReader` for the given stream. Parameters stream:QuicReceiverStream a receiver stream with no connected reader debug:Logger a logger

public QuicStreamIntReader(QuicReceiverStream stream, Logger debug)

Creates a QuicStreamIntReader for the given stream.

Parameters

stream:QuicReceiverStream: a receiver stream with no connected reader
debug:Logger: a logger

Method Detail

dispatch	back to summary
private void dispatch()

readInt back to summary

readInt	back to summary
public synchronized CompletableFuture<Long> readInt() Starts a read operation to decode a single number. Returns:CompletableFuture<Long> a `CompletableFuture<Long>` that will be completed with the decoded number, or -1 if the stream is terminated before the complete number could be read, or an exception if the stream is reset or decoding fails. Exceptions IllegalStateException: if the reader is stopped, or if a read operation is already in progress

public synchronized CompletableFuture<Long> readInt()

Starts a read operation to decode a single number.

Returns:CompletableFuture<Long>

a CompletableFuture<Long> that will be completed with the decoded number, or -1 if the stream is terminated before the complete number could be read, or an exception if the stream is reset or decoding fails.

Exceptions

IllegalStateException:: if the reader is stopped, or if a read operation is already in progress

stop back to summary

stop	back to summary
public synchronized void stop() Stops and disconnects this reader. This operation must not be done when a read operation is in progress. If cancelling a read operation is intended, use `QuicReceiverStream#requestStopSending(long)`. Exceptions IllegalStateException: if a read operation is currently in progress.

public synchronized void stop()

Stops and disconnects this reader. This operation must not be done when a read operation is in progress. If cancelling a read operation is intended, use QuicReceiverStream#requestStopSending(long).