Struct radiorust::blocks::io::raw::ContinuousClosureSink

pub struct ContinuousClosureSink<T, E> { /* private fields */ }

Block acting as Consumer, which uses a callback as sink and aborts when stream is reset

The type argument E indicates a possible reported error type by the callback.

Implementations

impl<T, E> ContinuousClosureSink<T, E>where
    T: Clone + Send + Sync + 'static,
    E: Send + 'static,

pub fn new<F>(process: F) -> Selfwhere
    F: FnMut(T) -> Result<(), E> + Send + 'static,

Create block which invokes the process closure for received data

pub fn new_async<F, R>(process: F) -> Selfwhere
    F: FnMut(T) -> R + Send + 'static,
    R: Future<Output = Result<(), E>> + Send,

Create block which invokes the process closure for received data and awaits its result

This function is the same as ContinuousClosureSink::new but accepts an asynchronously working closure.

pub fn detach(self)

Consume the block but continue operation until interruption or completion

pub async fn wait(self) -> Result<bool, ContinuousClosureSinkError<E>>

Wait for stream to finish

Returns Ok(true) if connected Producer indicated completion through Sender::finish (RecvError::Finished). Returns Ok(false) if operation could not complete because no Producer is connected.

pub async fn stop(self) -> Result<bool, ContinuousClosureSinkError<E>>

Stop operation

Returns Ok(true) if connected Producer indicated completion through Sender::finish (RecvError::Finished). Returns Ok(false) if operation was stopped before.

Trait Implementations

impl<T, E> Consumer<T> for ContinuousClosureSink<T, E>where
    T: Clone,

fn receiver_connector(&self) -> &ReceiverConnector<T>

Obtain reference to ReceiverConnector

fn feed_from<P: Producer<T>>(&self, producer: &P)

Connect Consumer to Producer

fn feed_from_none(&self)

Disconnect Consumer from any connected Producer if connected

fn connect_to_producer<P: Producer<T>>(&self, producer: &P)

👎Deprecated since 0.2.0: method has been renamed to feed_from

Connect Consumer to Producer

fn disconnect_from_producer(&self)

👎Deprecated since 0.2.0: method has been renamed to feed_from_none

Disconnect Consumer from any connected Producer if connected