Struct radiorust::blocks::io::raw::ClosureSink

pub struct ClosureSink<T> { /* private fields */ }

Block acting as Consumer, which uses a callback as sink

RecvErrors are ignored by this block. Use ContinuousClosureSink if you need a guarantee that the received data is complete and without interruptions.

Implementations

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

pub fn new<F>(process: F) -> Selfwhere
    F: FnMut(T) + 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 = ()> + Send,

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

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

pub fn detach(self)

Consume the block but continue operation as long as there is a connected Producer

pub async fn wait(self)

Wait as long as there is a connected Producer

pub async fn stop(self)

Stop operation

This is effectively the same as dropping the block, but a panic in the background task is propagated to the caller of stop.

Trait Implementations

impl<T> Consumer<T> for ClosureSink<T>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