Struct BidiStream 

pub struct BidiStream<B>
where
    B: Buf,
{ /* private fields */ }

QUIC-backed bidirectional stream

Implements http3::quic::BidiStream which allows the stream to be split into two structs each implementing one direction.

Trait Implementations

impl<B> BidiStream<B> for BidiStream<B>

where B: Buf,

type SendStream = SendStream<B>

The type for the send half.

type RecvStream = RecvStream

The type for the receive half.

fn split(self) -> (Self::SendStream, Self::RecvStream)

Split this stream into two halves.

impl<B> Is0rtt for BidiStream<B>

where B: Buf,

fn is_0rtt(&self) -> bool

Check if this stream was opened during 0-RTT.

impl<B: Buf> RecvStream for BidiStream<B>

type Buf = Bytes

The type of Buf for data received on this stream.

fn poll_data( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Option<Self::Buf>, StreamErrorIncoming>>

Poll the stream for more data.

fn stop_sending(&mut self, error_code: u64)

Send a STOP_SENDING QUIC code.

fn recv_id(&self) -> StreamId

Get QUIC send stream id

impl<B> SendStream<B> for BidiStream<B>

where B: Buf,

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

Polls if the stream can send more data.

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

Poll to finish the sending side of the stream.

fn poll_stopped( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Option<u64>, StreamErrorIncoming>>

Polls the peer’s response to the send direction.

fn reset(&mut self, reset_code: u64)

Send a QUIC reset code.

fn send_data<D: Into<WriteBuf<B>>>( &mut self, data: D, ) -> Result<(), StreamErrorIncoming>

Send more data on the stream.

fn send_id(&self) -> StreamId

Get QUIC send stream id

impl<B> SendStreamUnframed<B> for BidiStream<B>

where B: Buf,

fn poll_send<D: Buf>( &mut self, cx: &mut Context<'_>, buf: &mut D, ) -> Poll<Result<usize, StreamErrorIncoming>>

Attempts to write data into the stream.