Struct LocalSender 

pub struct LocalSender<S: Service>(/* private fields */);

A local sender for the service S using the message type M.

This is a wrapper around an in-memory channel (currently tokio::sync::mpsc::Sender), that adds nice syntax for sending messages that can be converted into WithChannels.

Implementations

impl<S: Service> LocalSender<S>

pub fn send<T>( &self, value: impl Into<WithChannels<T, S>>, ) -> impl Future<Output = Result<(), SendError>> + Send + 'static

where T: Channels<S>, S::Message: From<WithChannels<T, S>>,

Send a message to the service

pub fn send_raw( &self, value: S::Message, ) -> impl Future<Output = Result<(), SendError>> + Send + 'static

Send a message to the service without the type conversion magic

Trait Implementations

impl<S: Service> Clone for LocalSender<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + Service> Debug for LocalSender<S>

where S::Message: Debug,

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

Formats the value using the given formatter.

impl<S: Service> From<LocalSender<S>> for Client<S>

fn from(tx: LocalSender<S>) -> Self

Converts to this type from the input type.

impl<S: Service> From<Sender<<S as Service>::Message>> for LocalSender<S>

fn from(tx: Sender<S::Message>) -> Self

Converts to this type from the input type.

impl<S: Service> From<Sender<<S as Service>::Message>> for LocalSender<S>

fn from(tx: Sender<S::Message>) -> Self

Converts to this type from the input type.