Struct fire_http_api::stream::streamer::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