async fn run(mut self) {
        while let Err(e) = (&mut self).run_inner().await {
            // todo: replace with tracing::warn!
            eprintln!(
                "Worker '{}' experienced an error and is re-starting: {}",
                self.ctx.address(),
                e.to_string()
            );
        }
    }
/// Run the inner worker and restart it if errors occurs
Run the inner worker and restart it if errors occurs
Run the inner worker and restart it if errors occurs
async fn run(mut self) {
        while let Err(e) = (&mut self).run_inner().await {
            // todo: replace with tracing::warn!
            eprintln!(
                "Worker '{}' experienced an error and is re-starting: {}",
                self.ctx.address(),
                e.to_string()
            );
        }
    }
async fn run ( mut self ) { while let Err ( e ) = ( & mut self ) . run_inner ( ) . await { // todo: replace with tracing::warn! eprintln ! ( " " self ctx address ( ) e to_string ( ) ) ; } }
Run the inner worker and restart it if errors occurs
Run the inner worker and restart it if errors occurs
mut self
mut self