Struct rabble::ThreadHandler

pub struct ThreadHandler<T: Encodable + Decodable + Debug + Clone> { /* fields omitted */ }

Methods

impl<T> ThreadHandler<T> where T: Encodable + Decodable + Debug + Clone

fn new<F>(callback: F) -> ThreadHandler<T> where F: Fn(&Node<T>, Envelope<T>) + 'static + Send

Trait Implementations

impl<T> ServiceHandler<T> for ThreadHandler<T> where T: Encodable + Decodable + Debug + Clone

fn handle_envelope(&mut self,
                   node: &Node<T>,
                   envelope: Envelope<T>,
                   _: &Registrar)
                   -> Result<()>

Handle any envelopes addressed to the service's Pid. All handlers must implement this function.

fn init(&mut self, &Registrar, &Node<T>) -> Result<()>

A callback function used to initialize the handler.

fn handle_notification(&mut self,
                       &Node<T>,
                       Notification,
                       &Registrar)
                       -> Result<()>

Handle poll notifications. Some handler don't register anything that requires notification and only receive envelopes. Those handlers do not need to implement this function.