async fn process_request(&mut self, request: SpuChangeRequest) {
        // process SPU action; update context with new actions
        match self.spu_reducer.process_requests(request) {
            Ok(actions) => {
                debug!("SPU Controller apply actions: {}", actions);
                // send actions to kv
                if actions.spus.count() > 0 {
                    for ws_action in actions.spus.into_iter() {
                        log_on_err!(self.ws_service.update_spu(ws_action).await);
                    }
                }
                if actions.conns.count() > 0 {
                    self.conn_manager.process_requests(actions.conns).await;
                }
            }
            Err(err) => error!("error generating spu actions from reducer: {}", err),
        }
    }
/// 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: SpuChangeRequest) {
        // process SPU action; update context with new actions
        match self.spu_reducer.process_requests(request) {
            Ok(actions) => {
                debug!("SPU Controller apply actions: {}", actions);
                // send actions to kv
                if actions.spus.count() > 0 {
                    for ws_action in actions.spus.into_iter() {
                        log_on_err!(self.ws_service.update_spu(ws_action).await);
                    }
                }
                if actions.conns.count() > 0 {
                    self.conn_manager.process_requests(actions.conns).await;
                }
            }
            Err(err) => error!("error generating spu actions from reducer: {}", err),
        }
    }
async fn process_request ( & mut self , request : SpuChangeRequest ) { // process SPU action; update context with new actions match self . spu_reducer . process_requests ( request ) { Ok ( actions ) => { debug ! ( " " actions ) ; // send actions to kv if actions . spus . count ( ) > 0 { for ws_action in actions . spus . into_iter ( ) { log_on_err ! ( self ws_service update_spu ( ws_action ) await ) ; } } if actions . conns . count ( ) > 0 { self . conn_manager . process_requests ( actions . conns ) . await ; } } Err ( err ) => error ! ( " " err ) , } }
process requests related to SPU management
process requests related to SPU management
&mut self
request
SpuChangeRequest
&mut self
request
SpuChangeRequest