Struct near_async::messaging::LateBoundSender

pub struct LateBoundSender<S> { /* private fields */ }

Sometimes we want to be able to pass in a sender that has not yet been fully constructed. LateBoundSender can act as a placeholder to pass CanSend and CanSendAsync capabilities through to the inner object. bind() should be called when the inner object is ready. All calls to send() and send_async() through this wrapper will block until bind() is called.

This struct is intended to be wrapped with an Arc, e.g. let late_bound = Arc::new(LateBoundSender::default()); let something_else = SomethingElse::new(late_bound.as_sender()); let implementation = Implementation::new(something_else); late_bound.bind(implementation);

Implementations

impl<S> LateBoundSender<S>

pub fn bind(&self, sender: S)

Trait Implementations

impl<M, S: CanSend<M>> CanSend<M> for LateBoundSender<S>

Allows LateBoundSender to be convertible to a Sender as long as the inner object could be.

fn send(&self, message: M)

impl<M, R, S: CanSendAsync<M, R>> CanSendAsync<M, R> for LateBoundSender<S>

Allows LateBoundSender to be convertible to an AsyncSender as long as the inner object could be.

fn send_async(&self, message: M) -> BoxFuture<'static, R>

impl<S> Default for LateBoundSender<S>

fn default() -> Self

Returns the “default value” for a type.