Struct StreamSender 

pub(crate) struct StreamSender {
    pub(super) id: u32,
    pub(super) shared: Arc<Shared>,
    pub(super) reset: CancellationToken,
    pub(super) queued: Arc<Queued>,
    pub(super) closed: bool,
    pub(super) _live: Arc<Live>,
}

The sending side of a stream. Dropping it without closing it resets the stream.

Fields

id: u32

shared: Arc<Shared>

reset: CancellationToken

queued: Arc<Queued>

The frames of the stream in the data queue.

closed: bool

_live: Arc<Live>

Implementations

impl StreamSender

pub(crate) async fn send(&mut self, data: Bytes) -> Result<()>

Send data in a single frame, at most MAX_DATA_FRAME_LEN bytes. Fails once the stream got reset or the connection ended.

async fn queue(&self, fin: bool, data: Bytes) -> Result<()>

Queue a data frame for the writer.

pub(crate) async fn close(&mut self) -> Result<()>

Close the sending side after the data sent before. A close which got cancelled leaves the stream to its drop, which resets it.

pub(super) fn reset(&mut self)

Reset the stream, both sides end. The data queued for the stream before goes out first. Users reset a stream by dropping it without closing it, the tests also directly.

pub(crate) async fn reset_by_peer(&self)

Resolves once the client reset the stream or the connection ended.

pub(crate) fn is_reset(&self) -> bool

Whether the stream got reset or the connection ended.

Trait Implementations

impl Drop for StreamSender

fn drop(&mut self)

Executes the destructor for this type.

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.