Uses of Record Class
io.github.mahmoudimus.quic.connection.StreamId

Packages that use StreamId

Package

Description

io.github.mahmoudimus.quic.connection

The sans-I/O QUIC connection and endpoint, ported from quinn-proto: the Connection state machine (handshake, packet assembly and processing, key updates, closing and draining), the Endpoint that routes datagrams and answers with Version Negotiation, Retry and stateless resets, their configurations (TransportConfig, ServerConfig, ClientConfig, EndpointConfig), and the building blocks they are made of: range sets (RangeSet), reassembly of received data (Assembler), buffering of sent data (SendBuffer), streams and flow control (StreamsState), packet number spaces and ACK generation (PacketSpace), loss detection (Recovery), pacing (Pacer), path MTU discovery (MtuDiscovery) and timers (TimerTable).

Uses of StreamId in io.github.mahmoudimus.quic.connection

Fields in io.github.mahmoudimus.quic.connection with type parameters of type StreamId

Modifier and Type	Field	Description
final Set<StreamId>	Retransmits.maxStreamData	Streams that need a MAX_STREAM_DATA.
final Set<StreamId>	Retransmits.streamDataBlocked	Streams that need a STREAM_DATA_BLOCKED.

Methods in io.github.mahmoudimus.quic.connection that return StreamId

Modifier and Type	Method	Description
StreamId	StreamsState.accept(Dir dir)	Accepts a stream the peer opened.
StreamId	Connection.acceptStream(Dir dir)	Accepts a stream the peer opened.
StreamId	Retransmits.PendingReset.id()	Returns the value of the id record component.
StreamId	StreamEvent.Finished.id()	Returns the value of the id record component.
StreamId	StreamEvent.Readable.id()	Returns the value of the id record component.
StreamId	StreamEvent.Stopped.id()	Returns the value of the id record component.
StreamId	StreamEvent.Writable.id()	Returns the value of the id record component.
StreamId	StreamMeta.id()	Returns the value of the id record component.
static StreamId	StreamId.of(Side initiator, Dir dir, long index)	The stream ID of a stream type and index.
StreamId	StreamsState.open(Dir dir)	Opens a local stream.
StreamId	Connection.openStream(Dir dir)	Opens a stream.

Methods in io.github.mahmoudimus.quic.connection with parameters of type StreamId

Modifier and Type	Method	Description
boolean	StreamsState.canSendFlowControl(StreamId id)	Whether a MAX_STREAM_DATA for a stream would still be useful.
int	StreamId.compareTo(StreamId o)
void	Connection.finish(StreamId id)	Finishes a stream's sending side: a FIN follows the data written.
void	StreamsState.finish(StreamId id)	Finishes a stream: no more data will be written, and a FIN is queued.
boolean	StreamsState.isLocalUnopened(StreamId id)	Whether a local stream has never been opened.
int	StreamsState.priority(StreamId id)	A stream's priority.
int	Connection.read(StreamId id, ByteBuffer dst)	Reads stream data in order.
Chunks	StreamsState.read(StreamId id, boolean ordered, Retransmits retransmits)	Starts reading a stream.
boolean	Connection.receivedEarlyData(StreamId id)	Server: whether a stream the client opened carried data in 0-RTT packets, which an attacker may have replayed.
void	StreamsState.receivedMaxStreamData(StreamId id, long offset)	Processes a MAX_STREAM_DATA frame.
RecvState	Connection.recvState(StreamId id)	The state of a stream's receiving side.
RecvState	StreamsState.recvState(StreamId id)	The state of a stream's receiving part.
void	Connection.releaseRead(StreamId id)	Forgets a stream whose end of data Connection.read(io.github.mahmoudimus.quic.connection.StreamId, java.nio.ByteBuffer) reported, once the application no longer reads it.
void	StreamsState.reset(StreamId id, long errorCode, Retransmits retransmits)	Abandons sending on a stream (RESET_STREAM).
void	StreamsState.resetAcked(StreamId id)	Releases a stream whose RESET_STREAM was acknowledged.
void	Connection.resetStream(StreamId id, long errorCode)	Abandons a stream's sending side with RESET_STREAM.
SendState	Connection.sendState(StreamId id)	The state of a stream's sending side.
SendState	StreamsState.sendState(StreamId id)	The state of a stream's sending part.
void	Connection.setPriority(StreamId id, int priority)	Sets a stream's send priority; higher goes first.
void	StreamsState.setPriority(StreamId id, int priority)	Sets a stream's priority; streams with a higher priority send first.
void	StreamsState.stop(StreamId id, long errorCode, Retransmits retransmits)	Stops receiving a stream (STOP_SENDING).
long	Connection.stopped(StreamId id)	Whether the peer sent STOP_SENDING for a stream.
long	StreamsState.stopped(StreamId id)	Whether the peer stopped a stream.
void	Connection.stopSending(StreamId id, long errorCode)	Asks the peer to stop sending on a stream (STOP_SENDING); unread data is discarded.
long	StreamsState.streamDataBlockedLimit(StreamId id)	The limit to put in a STREAM_DATA_BLOCKED for a stream.
long	StreamsState.takeReset(StreamId id, Retransmits retransmits)	Whether the peer reset a stream.
int	Connection.write(StreamId id, ByteBuffer data)	Writes stream data, copying as much as flow control and the send window allow.
int	StreamsState.write(StreamId id, ByteBuffer data, Retransmits pending)	Writes data, copying as much as flow control and the send window accept.
StreamsState.Written	StreamsState.writeChunks(StreamId id, ByteBuffer[] chunks, Retransmits pending)	Writes buffers without copying them: the stream keeps views until the data is acknowledged, so their contents must not change.

Constructors in io.github.mahmoudimus.quic.connection with parameters of type StreamId

Modifier	Constructor	Description
	Finished(StreamId id)	Creates an instance of a Finished record class.
	PendingReset(StreamId id, long errorCode)	Creates an instance of a PendingReset record class.
	Readable(StreamId id)	Creates an instance of a Readable record class.
	Stopped(StreamId id, long errorCode)	Creates an instance of a Stopped record class.
	StreamMeta(StreamId id, long start, long end, boolean fin)	Creates an instance of a StreamMeta record class.
	Writable(StreamId id)	Creates an instance of a Writable record class.