Struct Streamer

pub struct Streamer<M> { /* private fields */ }

Available on crate feature feature only.

Implementations

impl<M> Streamer<M>

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

where M: Serialize,

Panics

If you call this when the Stream::KIND is not Receiver

pub async fn closed(&self)

Completes when the receiver has dropped.

Panics

If you call this when the Stream::KIND is not Receiver

pub async fn recv(&mut self) -> Result<M, StreamError>

where M: DeserializeOwned,

Panics

If you call this when the Stream::KIND is not Sender

Trait Implementations

impl<'a, R, M> Extractor<'a, R> for Streamer<M>

where M: Send + 'static,

type Error = Infallible

type Prepared = Streamer<M>

fn validate(validate: Validate<'_>)

fn prepare( prepare: Prepare<'_>, ) -> Pin<Box<dyn Future<Output = Result<Self::Prepared, Self::Error>> + Send + '_>>

fn extract( extract: Extract<'a, '_, Self::Prepared, R>, ) -> Result<Self, Self::Error>

where Self: Sized,