Uses of Interface
org.eclipse.jetty.quic.api.Stream
Packages that use Stream
Package
Description
This module contains the main abstractions for the QUIC protocol using the Quiche library.
-
Uses of Stream in org.eclipse.jetty.quic.api
Methods in org.eclipse.jetty.quic.api that return StreamModifier and TypeMethodDescriptionSession.getStream
(long streamId) Session.newStream
(long streamId, Stream.Listener listener) Creates a new local QUIC stream with the given stream id and listener.Methods in org.eclipse.jetty.quic.api that return types with arguments of type StreamMethods in org.eclipse.jetty.quic.api with parameters of type StreamModifier and TypeMethodDescriptiondefault void
Invoked when the stream has beenclosed
.default void
Stream.Listener.onDataAvailable
(Stream stream) Callback method invoked when the application has expresseddemand
for data carried by STREAM frames, and there are STREAM frames available.default void
Stream.Listener.onDataBlocked
(Stream stream, StreamDataBlockedFrame frame) Invoked when a STREAM_DATA_BLOCKED frame has been received.default void
Invoked when a stream failure is detected.default void
Stream.Listener.onIdleTimeout
(Stream stream, TimeoutException failure, Promise.Invocable<Boolean> promise) Invoked when the stream is idle for longer than the idle timeout.default void
Stream.Listener.onMaxData
(Stream stream, StreamMaxDataFrame frame) Invoked when a MAX_STREAM_DATA frame has been received.default void
Stream.Listener.onNewStream
(Stream stream, Frame.WithStreamId frame) Callback method invoked when receiving a frame that causes the creation of a new stream.default void
Stream.Listener.onReset
(Stream stream, ResetFrame frame) Invoked when a RESET_STREAM frame has been received.default void
Stream.Listener.onStopSending
(Stream stream, StopSendingFrame frame) Invoked when a STOP_SENDING frame has been received.Method parameters in org.eclipse.jetty.quic.api with type arguments of type StreamModifier and TypeMethodDescriptionvoid
Stream.data
(boolean last, List<ByteBuffer> data, Promise.Invocable<Stream> promise) Sends a STREAM frame with the given data bytes and the indication of whether they are the last to be sent.void
Stream.dataBlocked
(long offset, Promise.Invocable<Stream> promise) Sends a STREAM_DATA_BLOCKED frame, with the given offset.void
Stream.disconnect
(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise) Abruptly terminates this stream with the given error.void
Stream.maxData
(long maxData, Promise.Invocable<Stream> promise) Sends a MAX_STREAM_DATA frame with the new total max data bytes that this peer is willing to receive.void
Stream.reset
(long appErrorCode, Promise.Invocable<Stream> promise) Sends a RESET_STREAM frame, with the given application error code.void
Stream.stopSending
(long appErrorCode, Promise.Invocable<Stream> promise) Sends a STOP_SENDING frame, with the given application error code. -
Uses of Stream in org.eclipse.jetty.quic.common
Classes in org.eclipse.jetty.quic.common that implement StreamMethods in org.eclipse.jetty.quic.common that return StreamMethods in org.eclipse.jetty.quic.common with parameters of type StreamModifier and TypeMethodDescriptionProtocolSession.createStreamEndPoint
(Stream stream, Consumer<StreamEndPoint> initializer) void
ProtocolStreamListener.onDataAvailable
(Stream stream) void
void
ProtocolStreamListener.onIdleTimeout
(Stream stream, TimeoutException failure, Promise.Invocable<Boolean> promise) void
ProtocolStreamListener.Server.onNewStream
(Stream stream, Frame.WithStreamId frame) Constructors in org.eclipse.jetty.quic.common with parameters of type Stream -
Uses of Stream in org.eclipse.jetty.quic.quiche
Classes in org.eclipse.jetty.quic.quiche that implement StreamMethods in org.eclipse.jetty.quic.quiche that return StreamModifier and TypeMethodDescriptionQuicheSession.newStream
(long streamId, Stream.Listener listener) Methods in org.eclipse.jetty.quic.quiche that return types with arguments of type StreamMethod parameters in org.eclipse.jetty.quic.quiche with type arguments of type StreamModifier and TypeMethodDescriptionvoid
QuicheStream.data
(boolean last, List<ByteBuffer> buffers, Promise.Invocable<Stream> promise) void
QuicheStream.dataBlocked
(long offset, Promise.Invocable<Stream> promise) void
QuicheStream.disconnect
(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise) void
QuicheStream.maxData
(long maxData, Promise.Invocable<Stream> promise) void
QuicheStream.reset
(long appErrorCode, Promise.Invocable<Stream> promise) void
QuicheStream.stopSending
(long appErrorCode, Promise.Invocable<Stream> promise)