Struct SenderMessage

pub struct SenderMessage { /* private fields */ }

Implementations

impl SenderMessage

pub fn new(cap: usize) -> (Self, (Receiver<Message>, Receiver<Message>))

pub async fn send<Transfer: MessageTransfer>( &self, msg: Transfer, ) -> BinaryOptionsResult<()>

pub async fn priority_send(&self, msg: Message) -> BinaryOptionsResult<()>

pub async fn send_message<Transfer: MessageTransfer, T: DataHandler<Transfer = Transfer>>( &self, data: &Data<T, Transfer>, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

pub async fn send_message_with_timout<Transfer: MessageTransfer, T: DataHandler<Transfer = Transfer>>( &self, time: Duration, task: impl ToString, data: &Data<T, Transfer>, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

pub async fn send_message_with_timeout_and_retry<Transfer: MessageTransfer, T: DataHandler<Transfer = Transfer>>( &self, time: Duration, task: impl ToString, data: &Data<T, Transfer>, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

Trait Implementations

impl Clone for SenderMessage

fn clone(&self) -> SenderMessage

Returns a copy of the value.

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

Performs copy-assignment from source.