Skip to content

Commit 5c74f20

Browse files
style: fix clippy lints
Co-Authored-By: Tejas Badadare <[email protected]>
1 parent a58dfdd commit 5c74f20

File tree

1 file changed

+11
-15
lines changed

1 file changed

+11
-15
lines changed

lazer/sdk/rust/consumer/src/client.rs

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ use {
88
},
99
subscription::{Request, Response, SubscribeRequest, SubscriptionId, UnsubscribeRequest},
1010
},
11-
serde_json,
1211
std::{
1312
collections::HashMap,
1413
sync::Arc,
@@ -108,24 +107,21 @@ impl PythLazerConsumer {
108107
message: Message,
109108
cache: &Arc<Mutex<TtlCache<String, ()>>>,
110109
) -> Result<()> {
111-
match message {
112-
Message::Text(text) => {
113-
if let Ok(response) = serde_json::from_str::<Response>(&text) {
114-
let msg_key = format!("{:?}", &response);
115-
let mut cache = cache.lock().await;
116-
117-
if cache.contains_key(&msg_key) {
118-
return Ok(());
119-
}
110+
if let Message::Text(text) = message {
111+
if let Ok(response) = serde_json::from_str::<Response>(&text) {
112+
let msg_key = format!("{:?}", &response);
113+
let mut cache = cache.lock().await;
120114

121-
cache.insert(msg_key, (), DEDUP_TTL);
115+
if cache.contains_key(&msg_key) {
116+
return Ok(());
117+
}
122118

123-
if let Err(e) = self.tx.send(response) {
124-
return Err(anyhow!("Failed to forward message: {}", e));
125-
}
119+
cache.insert(msg_key, (), DEDUP_TTL);
120+
121+
if let Err(e) = self.tx.send(response) {
122+
return Err(anyhow!("Failed to forward message: {}", e));
126123
}
127124
}
128-
_ => {}
129125
}
130126
Ok(())
131127
}

0 commit comments

Comments
 (0)