Trait salvo_core::proto::quic::SendStream

pub trait SendStream<B>
where
    B: Buf,
{
    type Error: Into<Box<dyn Error>>;

    // Required methods
    fn poll_ready(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<(), Self::Error>>;
    fn send_data<T>(&mut self, data: T) -> Result<(), Self::Error>
       where T: Into<WriteBuf<B>>;
    fn poll_finish(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<(), Self::Error>>;
    fn reset(&mut self, reset_code: u64);
    fn send_id(&self) -> StreamId;
}

Available on crate feature quinn only.

A trait describing the “send” actions of a QUIC stream.

Required Associated Types

type Error: Into<Box<dyn Error>>

The error type returned by fallible send methods.

Required Methods

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Polls if the stream can send more data.

fn send_data<T>(&mut self, data: T) -> Result<(), Self::Error>

where T: Into<WriteBuf<B>>,

Send more data on the stream.

fn poll_finish(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Poll to finish the sending side of the stream.

fn reset(&mut self, reset_code: u64)

Send a QUIC reset code.

fn send_id(&self) -> StreamId

Get QUIC send stream id

Object Safety

This trait is not object safe.

Implementors

impl<B> SendStream<B> for salvo_http3::http3_quinn::BidiStream<B>

where B: Buf,

type Error = SendStreamError

impl<B> SendStream<B> for salvo_http3::http3_quinn::SendStream<B>

where B: Buf,

type Error = SendStreamError

impl<S, B> SendStream<B> for salvo_core::webtransport::stream::BidiStream<S, B>

where S: SendStream<B>, B: Buf,

type Error = <S as SendStream<B>>::Error

impl<S, B> SendStream<B> for salvo_core::webtransport::stream::SendStream<S, B>

where S: SendStream<B>, B: Buf,

type Error = <S as SendStream<B>>::Error

impl<S, B> SendStream<B> for BufRecvStream<S, B>

where B: Buf, S: SendStream<B>,

type Error = <S as SendStream<B>>::Error

impl<T, B> SendStream<B> for FrameStream<T, B>

where T: SendStream<B>, B: Buf,

type Error = <T as SendStream<B>>::Error