mirror of
https://github.com/pcvolkmer/mv64e-kafka-to-rest-gateway
synced 2025-09-13 17:22:52 +00:00
refactor: replace let..if with let..else
This commit is contained in:
@@ -138,9 +138,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
|
||||
while let Ok(msg) = consumer.recv().await {
|
||||
if let Some(Ok(payload)) = msg.payload_view::<str>() {
|
||||
if let Some(Ok(key)) = msg.key_view::<str>() {
|
||||
let payload = if let Ok(payload) = serde_json::from_str::<Mtb>(payload) {
|
||||
payload
|
||||
} else {
|
||||
let Ok(payload) = serde_json::from_str::<Mtb>(payload) else {
|
||||
error!("Error deserializing payload");
|
||||
continue;
|
||||
};
|
||||
|
Reference in New Issue
Block a user