Struct s2n_quic_transport::stream::StreamImpl
source · pub struct StreamImpl { /* private fields */ }
Expand description
The implementation of a Stream
.
This is mostly a facade over the reading and writing half of the Stream
.
Trait Implementations§
source§impl Debug for StreamImpl
impl Debug for StreamImpl
source§impl Provider for StreamImpl
impl Provider for StreamImpl
source§fn timers<Q: Query>(&self, query: &mut Q) -> Result
fn timers<Q: Query>(&self, query: &mut Q) -> Result
Notifies the query of any timers owned by the provider Read more
source§fn next_expiration(&self) -> Option<Timestamp>
fn next_expiration(&self) -> Option<Timestamp>
Returns the next
Timestamp
at which the earliest timer is armed in the providersource§fn armed_timer_count(&self) -> usize
fn armed_timer_count(&self) -> usize
Counts the number of armed timers in the provider
source§fn for_each_timer<F>(&self, f: F)
fn for_each_timer<F>(&self, f: F)
Iterates over each timer in the provider and calls the provided function
source§impl StreamTrait for StreamImpl
impl StreamTrait for StreamImpl
source§fn new(config: StreamConfig) -> StreamImpl
fn new(config: StreamConfig) -> StreamImpl
Creates a new
Stream
instance with the given configurationsource§fn on_data(
&mut self,
frame: &StreamRef<'_>,
events: &mut StreamEvents
) -> Result<(), Error>
fn on_data( &mut self, frame: &StreamRef<'_>, events: &mut StreamEvents ) -> Result<(), Error>
This is called when a
STREAM_DATA
frame had been received for
this streamsource§fn on_stream_data_blocked(
&mut self,
frame: &StreamDataBlocked,
events: &mut StreamEvents
) -> Result<(), Error>
fn on_stream_data_blocked( &mut self, frame: &StreamDataBlocked, events: &mut StreamEvents ) -> Result<(), Error>
This is called when a
STREAM_DATA_BLOCKED
frame had been received for
this streamsource§fn on_reset(
&mut self,
frame: &ResetStream,
events: &mut StreamEvents
) -> Result<(), Error>
fn on_reset( &mut self, frame: &ResetStream, events: &mut StreamEvents ) -> Result<(), Error>
This is called when a
RESET_STREAM
frame had been received for
this streamsource§fn on_max_stream_data(
&mut self,
frame: &MaxStreamData,
events: &mut StreamEvents
) -> Result<(), Error>
fn on_max_stream_data( &mut self, frame: &MaxStreamData, events: &mut StreamEvents ) -> Result<(), Error>
This is called when a
MAX_STREAM_DATA
frame had been received for
this streamsource§fn on_stop_sending(
&mut self,
frame: &StopSending,
events: &mut StreamEvents
) -> Result<(), Error>
fn on_stop_sending( &mut self, frame: &StopSending, events: &mut StreamEvents ) -> Result<(), Error>
This is called when a
STOP_SENDING
frame had been received for
this streamsource§fn on_packet_ack<A: Set>(&mut self, ack_set: &A, events: &mut StreamEvents)
fn on_packet_ack<A: Set>(&mut self, ack_set: &A, events: &mut StreamEvents)
This method gets called when a packet delivery got acknowledged
source§fn on_packet_loss<A: Set>(&mut self, ack_set: &A, _events: &mut StreamEvents)
fn on_packet_loss<A: Set>(&mut self, ack_set: &A, _events: &mut StreamEvents)
This method gets called when a packet loss is reported
source§fn update_blocked_sync_period(&mut self, blocked_sync_period: Duration)
fn update_blocked_sync_period(&mut self, blocked_sync_period: Duration)
Updates the period at which
STREAM_DATA_BLOCKED
frames are sent to the peer
if the application is blocked by peer limits.source§fn on_timeout(&mut self, now: Timestamp)
fn on_timeout(&mut self, now: Timestamp)
Called when the connection timer expires
source§fn on_internal_reset(&mut self, error: StreamError, events: &mut StreamEvents)
fn on_internal_reset(&mut self, error: StreamError, events: &mut StreamEvents)
This method gets called when a stream gets reset due to a reason that is
not related to a frame. E.g. due to a connection failure.
source§fn on_flush(&mut self, error: StreamError, events: &mut StreamEvents)
fn on_flush(&mut self, error: StreamError, events: &mut StreamEvents)
This method is called when the application drops the connection Read more
source§fn on_transmit<W: WriteContext>(
&mut self,
context: &mut W
) -> Result<(), OnTransmitError>
fn on_transmit<W: WriteContext>( &mut self, context: &mut W ) -> Result<(), OnTransmitError>
Queries the component for any outgoing frames that need to get sent
source§fn on_connection_window_available(&mut self)
fn on_connection_window_available(&mut self)
This method is called when a connection window is available
fn poll_request( &mut self, request: &mut Request<'_>, context: Option<&Context<'_>> ) -> Result<Response, StreamError>
Auto Trait Implementations§
impl Freeze for StreamImpl
impl !RefUnwindSafe for StreamImpl
impl !Send for StreamImpl
impl !Sync for StreamImpl
impl Unpin for StreamImpl
impl !UnwindSafe for StreamImpl
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more