Struct SharedServiceThread

pub struct SharedServiceThread<S: Service> { /* private fields */ }

This runs a service into a thread but, unlike ServiceThread, it will use an Arc<Mutex<S>> so that the service object is also available as shared memory.

This is mostly here for backwards compatibility and to make adoption easier: start by using SharedServiceThread and when all usage of the shared memory have been removed, switch to ServiceThread for a “pure actor”.

Implementations

impl<S: Service + Send + 'static> SharedServiceThread<S>

pub fn spawn_with(service: S) -> Self

pub fn mbox(&self) -> Mailbox<S>

pub fn run( service: Arc<Mutex<S>>, receiver: Receiver<Envelope<S>>, ) -> Result<StatsAggregator, &'static str>

pub fn shared(&self) -> Arc<Mutex<S>>