Struct MpscSender 

pub struct MpscSender<Value, NextAccepts> { /* private fields */ }

Sends values through an mpsc::Sender and forwards the Result downstream.

Implementations

impl<Value, NextAccepts> MpscSender<Value, NextAccepts>

pub fn new(sender: Sender<Value>, next_acceptor: NextAccepts) -> Self

Trait Implementations

impl<Value, NextAccepts> Accepts<Value> for MpscSender<Value, NextAccepts>

where NextAccepts: Accepts<Result<(), SendError<Value>>>,

fn accept(&self, value: Value)

impl<Value, NextAccepts> AsyncAccepts<Value> for MpscSender<Value, NextAccepts>

where NextAccepts: AsyncAccepts<Result<(), SendError<Value>>>,

fn accept_async<'a>(&'a self, value: Value) -> impl Future<Output = ()> + 'a

where Value: 'a,

impl<Value: Clone, NextAccepts: Clone> Clone for MpscSender<Value, NextAccepts>

fn clone(&self) -> MpscSender<Value, NextAccepts>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Value: Debug, NextAccepts: Debug> Debug for MpscSender<Value, NextAccepts>

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

Formats the value using the given formatter.