Trait my_iot::services::Service

pub trait Service: Send {
    fn spawn(
        self: Box<Self>, 
        db: Arc<Mutex<Db>>, 
        tx: &BroadcastSender<Message>, 
        rx: &BroadcastReceiver<Message>
    ) -> Result<(), Error>;
}

A generic service.

Required methods

fn spawn(
    self: Box<Self>,
    db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

Spawn service threads.

Service may spawn as much threads as needed and must take care of their health.

• db: database.
• tx: 0-capacity channel sender.
• rx: 0-capacity channel receiver.

Loading content...

Implementors

impl Service for Automator

fn spawn(
    self: Box<Self>,
    _db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

impl Service for Buienradar

fn spawn(
    self: Box<Self>,
    _db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    _rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

impl Service for Clock

fn spawn(
    self: Box<Self>,
    _db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    _rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

impl Service for Db

fn spawn(
    self: Box<Self>,
    db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    _rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

impl Service for Nest

fn spawn(
    self: Box<Self>,
    _db: Arc<Mutex<Db>>,
    tx: &BroadcastSender<Message>,
    _rx: &BroadcastReceiver<Message>
) -> Result<(), Error>

Loading content...