Skip to main content

SendStream

Struct SendStream 

Source
pub struct SendStream { /* private fields */ }
Expand description

An outgoing stream, WebTransport-framed when its session is.

finish can leave the WebTransport header owed, when the connection has no flow-control credit for it. The FIN then goes out on a later poll_closed, or on Drop if credit has returned by then. Dropping immediately after finishing, with no poll in between, leaves no moment for it to return and cancels the stream instead, so pair the two when a clean end matters.

Trait Implementations§

Source§

impl Debug for SendStream

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Drop for SendStream

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)
Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more
Source§

impl SendStream for SendStream

Source§

type Error = Error

The error type for every operation on this stream.
Source§

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

Poll to write some of the buffer to the stream, returning how many bytes were written. See poll_write_buf for the partial-write contract, which this shares.
Source§

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

Poll to write some of the given buffer to the stream, advancing it by the number of bytes written. This may be less than the whole buffer, so callers loop. Read more
Source§

fn set_priority(&mut self, order: u8)

Set the stream’s priority. Read more
Source§

fn finish(&mut self) -> Result<(), Self::Error>

Mark the stream as finished, erroring on any future writes. Read more
Source§

fn reset(&mut self, code: u32)

Immediately closes the stream and discards any remaining data. Read more
Source§

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

Poll until the stream is closed by either side. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<S> SendStream for S
where S: SendStream + 'static,

Source§

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

Write some of the buffer, returning how many bytes were accepted.
Source§

fn write_buf<'a, B>(&'a mut self, buf: &'a mut B) -> WriteBuf<'a, Self, B> ⓘ
where B: Buf,

Write some of the buffer, advancing it by the bytes accepted.
Source§

fn write_chunk(&mut self, chunk: Bytes) -> WriteChunk<'_, Self> ⓘ

Write the entire chunk to the stream.
Source§

fn closed(&mut self) -> SendClosed<'_, Self> ⓘ

Wait until the stream is closed by either side.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more