Struct Stream 

pub struct Stream { /* private fields */ }

One streaming session, on either side. Cloning it shares the session.

Implementations

impl Stream

pub fn request(&self) -> &VerifiedRequest

The stream’s verified STREAM_OPEN: its caller, procedure, mode and payload.

pub async fn send(&self, body: &[u8]) -> Result<(), LinkError>

Sends a raw chunk.

pub async fn send_value(&self, v: Value) -> Result<(), LinkError>

Sends a structured chunk.

pub async fn close_send(&self) -> Result<(), LinkError>

Ends this side’s sending; the peer may still send.

pub async fn close(&self) -> Result<(), LinkError>

Ends the stream on both sides.

pub async fn reply(&self, payload: Value) -> Result<(), LinkError>

Sends the provider’s terminal value and ends the stream.

pub async fn abort(&self, code: &str, message: &str) -> Result<(), LinkError>

Ends the stream with a STREAM_ERROR of code and message.

pub async fn recv(&self) -> Result<StreamEvent, LinkError>

The next frame the peer sent. After the stream ends, once every event before it is read, it returns LinkError::EndOfStream for a normal end and the error that ended it otherwise.

pub async fn done(&self) -> Option<LinkError>

Waits until the stream has ended and been released, and says why: None for a normal end.

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.