async fn process_response(
        &self,
        response: &Self::Response,
        state: Arc<RwLock<State>>,
    ) -> Result<()> {
        if let Some(Ok(response)) = response.responses.iter().rfind(|response| response.is_ok()) {
            let state = state.read().await;
            // TODO: Incorporate error into process response
            state.set_remaining_orders(response.remaining_orders);
        }
        Ok(())
    }
/// Update the number of orders remaining before state sync
Update the number of orders remaining before state sync
Update the number of orders remaining before state sync
async fn process_response(
        &self,
        response: &Self::Response,
        state: Arc<RwLock<State>>,
    ) -> Result<()> {
        if let Some(Ok(response)) = response.responses.iter().rfind(|response| response.is_ok()) {
            let state = state.read().await;
            // TODO: Incorporate error into process response
            state.set_remaining_orders(response.remaining_orders);
        }
        Ok(())
    }
async fn process_response ( & self , response : & Self :: Response , state : Arc < RwLock < State > > , ) -> Result < ( ) > { if let Some ( Ok ( response ) ) = response . responses . iter ( ) . rfind ( | response | response . is_ok ( ) ) { let state = state . read ( ) . await ; // TODO: Incorporate error into process response state . set_remaining_orders ( response . remaining_orders ) ; } Ok ( ( ) ) }
Update the number of orders remaining before state sync
Update the number of orders remaining before state sync
&self
response
&Self::Response
state
Arc<RwLock<State>>