Struct FlumeInbox 

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

A wrapper around a flume::Sender that acts as a PolyBox.

Implementations

impl<T> FlumeInbox<T>

pub fn new(buffer: usize) -> (Self, Receiver<T>)

pub fn inner(&self) -> &Sender<T>

pub fn into_inner(self) -> Sender<T>

pub fn from_inner(sender: Sender<T>) -> Self

Trait Implementations

impl<T> Clone for FlumeInbox<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Interface> DynPolyBox for FlumeInbox<T>

fn _send_boxed_payload_checked( &self, msg: BoxedPayload, ) -> BoxFuture<'_, Result<(), SendCheckedError<BoxedPayload>>>

Send a boxed payload.

fn _send_boxed_payload_checked_blocking( &self, msg: BoxedPayload, ) -> Result<(), SendCheckedError<BoxedPayload>>

Same as Self::_send_boxed_payload_checked, but blocks the current thread until the message is sent.

impl<T: Interface> PolyBox for FlumeInbox<T>

type Set = <T as AsSet>::Set

The set of message types that this inbox can accept.

fn into_dyn_unchecked<R>(self) -> DynInbox<R>

Converts into a dynamic inbox without checking if the types are compatible.

impl<T, R> Sends<T> for FlumeInbox<R>

where T: Message, R: TryIntoPayload<T> + FromPayload<T> + Send,

async fn send(&self, msg: T) -> Result<Output<T>, SendError<T>>

Sends a message of type T to the inbox.

fn send_blocking( &self, msg: T, ) -> Result<<<T as Message>::Kind as MessageSpecifier<T>>::Output, SendError<T>>

Same as Sends::send, but blocks the current thread until the message is sent.