Method run

src/processor.rs:69–86

(mut self)

    #[inline]
    pub fn run(mut self) {        
        // spawn
        tokio::spawn(async move {

            self.proc.init().await;
            
            while let Some(msg) = self.recv.recv().await {
                match self.proc.handle_message(msg).await {
                    ProcResult::Continue => (),
                    ProcResult::Dispatch(m, pk) => {

                        let _ = self.dispatcher.dispatch(m, pk).await;

                    }
                }
            }
        });
    }
}