simplify that

iopsystems · Oct 19, 2023 · d0c2e4f · d0c2e4f
1 parent 6fe90d9
commit d0c2e4f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/pubsub/kafka.rs b/src/pubsub/kafka.rs
@@ -163,9 +163,7 @@ async fn subscriber_task(client: Arc<StreamConsumer>, topics: Vec<String>) {
             match client.recv().await {
                 Ok(message) => match message.payload_view::<[u8]>() {
                     Some(Ok(message)) => {
-                        let mut message = message.to_owned();
-
-                        match validator.validate(&mut message) {
+                        match validator.validate(&mut message.to_owned()) {
                             Err(ValidationError::Unexpected) => {
                                 error!("pubsub: invalid message received");
                                 RESPONSE_EX.increment();