pub async fn process(mut self) {
        while let Ok(Some(mut req)) = self.request_stream.try_next().await {
            for processing_unit in &self.processing_units {
                // If the processing unit consumes the request (a non-empty
                // result is returned) or an error occurs, exit processing this
                // request. Otherwise, hand the request to the next processing
                // unit
                match processing_unit.process(self.switchboard_client.clone(), req).await {
                    Ok(Some(return_request)) => {
                        req = return_request;
                    }
                    _ => {
                        break;
                    }
                }
            }
        }
    }
// Process the stream. Note that we pass in the processor here as it cannot
// be used again afterwards.
Process the stream. Note that we pass in the processor here as it cannot
be used again afterwards.
Process the stream . Note that we pass in the processor here as it cannot be used again afterwards .
pub async fn process(mut self) {
        while let Ok(Some(mut req)) = self.request_stream.try_next().await {
            for processing_unit in &self.processing_units {
                // If the processing unit consumes the request (a non-empty
                // result is returned) or an error occurs, exit processing this
                // request. Otherwise, hand the request to the next processing
                // unit
                match processing_unit.process(self.switchboard_client.clone(), req).await {
                    Ok(Some(return_request)) => {
                        req = return_request;
                    }
                    _ => {
                        break;
                    }
                }
            }
        }
    }
pub async fn process ( mut self ) { while let Ok ( Some ( mut req ) ) = self . request_stream . try_next ( ) . await { for processing_unit in & self . processing_units { // If the processing unit consumes the request (a non-empty // result is returned) or an error occurs, exit processing this // request. Otherwise, hand the request to the next processing // unit match processing_unit . process ( self . switchboard_client . clone ( ) , req ) . await { Ok ( Some ( return_request ) ) => { req = return_request ; } _ => { break ; } } } } }
Process the stream.
Process the stream .
mut self
mut self