bugfix: deadlock with channel usage

ralexstokes · Apr 26, 2024 · f071d56 · f071d56
1 parent ec8b827
commit f071d56
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/mev-build-rs/src/builder.rs b/mev-build-rs/src/builder.rs
@@ -210,7 +210,16 @@ impl<
         loop {
             tokio::select! {
                 Some(message) = self.msgs.recv() => self.dispatch(message).await,
-                Some(Ok(Events::Attributes(attributes))) = payload_events.next() => self.on_payload_attributes(attributes).await,
+                Some(event) = payload_events.next() => match event {
+                    Ok(event) => {
+                        if let Events::Attributes(attributes) = event {
+                            self.on_payload_attributes(attributes).await;
+                        }
+                    }
+                    Err(err) => {
+                        warn!(%err, "error getting payload events");
+                    }
+                }
             }
         }
     }