Struct dbs_utils::epoll_manager::RemoteEndpoint

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

Enables interactions with an EventManager that runs on a different thread of execution.

Implementations

impl<S> RemoteEndpoint<S>where
    S: MutEventSubscriber,

pub fn call_blocking<F, O, E>(&self, f: F) -> Result<O, E>where
    F: 'static + FnOnce(&mut dyn SubscriberOps<Subscriber = S>) -> Result<O, E> + Send,
    O: 'static + Send,
    E: 'static + From<Error> + Send,

Call the specified closure on the associated remote EventManager (provided as a SubscriberOps trait object), and return the result. This method blocks until the result is received, and calling it from the same thread where the event loop runs leads to a deadlock.

pub fn fire<F>(&self, f: F) -> Result<(), Error>where
    F: 'static + FnOnce(&mut dyn SubscriberOps<Subscriber = S>) + Send,

Call the specified closure on the associated local/remote EventManager (provided as a SubscriberOps trait object), and discard the result. This method only fires the request but does not wait for result, so it may be called from the same thread where the event loop runs.

pub fn kick(&self) -> Result<(), Error>

Kick the worker thread to wake up from the epoll event loop.

Trait Implementations

impl<S> Clone for RemoteEndpoint<S>

fn clone(&self) -> RemoteEndpoint<S>

Returns a copy of the value.

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

Performs copy-assignment from source.