Struct radiorust::flow::ReceiverConnector

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

Handle to connect a Receiver to a Sender

A ReceiverConnector is either obtained when calling new_receiver or by calling ReceiverConnector::new.

Connecting a Receiver to a Sender is done by passing a SenderConnector reference to ReceiverConnector::connect. The SenderConnector is obtained when calling new_sender.

Implementations

impl<T> ReceiverConnector<T>

pub fn new() -> Self

Create a new ReceiverConnector without associated Receivers

pub fn connect(&self, connector: &SenderConnector<T>)

Connect associated Receivers with a Sender

pub fn disconnect(&self)

Disconnect associated Receivers from Sender if connected

pub fn stream(&self) -> Receiver<T>

Obtain an associated Receiver

Trait Implementations

impl<T> Consumer<T> for ReceiverConnector<T>

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

impl<T: Debug> Debug for ReceiverConnector<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.