Uses of Class
io.github.mahmoudimus.quic.connection.StreamException

Packages that use StreamException

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 StreamException in io.github.mahmoudimus.quic.connection

Methods in io.github.mahmoudimus.quic.connection that throw StreamException

Modifier and Type	Method	Description
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.
Chunk	Chunks.next(int maxLength)	The next chunk.
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.
void	StreamsState.reset(StreamId id, long errorCode, Retransmits retransmits)	Abandons sending on a stream (RESET_STREAM).
void	Connection.resetStream(StreamId id, long errorCode)	Abandons a stream's sending side with RESET_STREAM.
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.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.