Struct quinn::generic::SendStream

pub struct SendStream<S> where
    S: Session,  { /* fields omitted */ }

A stream that can only be used to send data

If dropped, streams that haven’t been explicitly reset will continue to (re)transmit previously written data until it has been fully acknowledged or the connection is closed.

Implementations

impl<S> SendStream<S> where
    S: Session, 

pub fn write<'a>(&'a mut self, buf: &'a [u8]) -> Write<'a, S>

Write bytes to the stream

Yields the number of bytes written on success. Congestion and flow control may cause this to be shorter than buf.len(), indicating that only a prefix of buf was written.

pub fn write_all<'a>(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, S>

Convenience method to write an entire buffer to the stream

pub fn finish(&mut self) -> Finish<'_, S>

Shut down the send stream gracefully.

No new data may be written after calling this method. Completes when the peer has acknowledged all sent data, retransmitting data as needed.

pub fn reset(&mut self, error_code: VarInt)

Close the send stream immediately.

No new data can be written after calling this method. Locally buffered data is dropped, and previously transmitted data will no longer be retransmitted if lost. If poll_finish was called previously and all data has already been transmitted at least once, the peer may still receive all written data.

Trait Implementations

impl<S> AsyncWrite for SendStream<S> where
    S: Session, 

fn poll_write(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &[u8]
) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

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

Attempt to close the object.

pub fn poll_write_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    bufs: &[IoSlice<'_>]
) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<S> AsyncWrite for SendStream<S> where
    S: Session, 

fn poll_write(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &[u8]
) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

pub fn poll_write_buf<B>(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &mut B
) -> Poll<Result<usize, Error>> where
    B: Buf, 

Writes a Buf into this value, returning how many bytes were written.

impl<S: Debug> Debug for SendStream<S> where
    S: Session, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S> Drop for SendStream<S> where
    S: Session, 

fn drop(&mut self)

Executes the destructor for this type.