/// process requests related to SPU management
process requests related to SPU management
process requests related to SPU management
async fn process_request(&mut self, request: TopicChangeRequest) {
        match self.reducer.process_requests(request) {
            Ok(actions) => {
                trace!("Topic actions: {}", actions);
                if actions.topics.count() > 0 {
                    for ws_action in actions.topics.into_iter() {
                        log_on_err!(self.ws_service.update_topic(ws_action).await);
                    }
                }
                if actions.partitions.count() > 0 {
                    for ws_action in actions.partitions.into_iter() {
                        log_on_err!(self.ws_service.update_partition(ws_action).await)
                    }
                }
            }
            Err(err) => error!("error processing topic spu: {}", err),
        }
    }
async fn process_request ( & mut self , request : TopicChangeRequest ) { match self . reducer . process_requests ( request ) { Ok ( actions ) => { trace ! ( " " actions ) ; if actions . topics . count ( ) > 0 { for ws_action in actions . topics . into_iter ( ) { log_on_err ! ( self ws_service update_topic ( ws_action ) await ) ; } } if actions . partitions . count ( ) > 0 { for ws_action in actions . partitions . into_iter ( ) { log_on_err ! ( self ws_service update_partition ( ws_action ) await ) } } } Err ( err ) => error ! ( " " err ) , } }
process requests related to SPU management
process requests related to SPU management
&mut self
request
TopicChangeRequest