Skip to content

Commit c0e848a

Browse files
authored
fix(ress): do not terminate on dropped commands sender (#15007)
1 parent 37f8a52 commit c0e848a

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

crates/ress/protocol/src/connection.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -273,8 +273,7 @@ where
273273
}
274274

275275
'conn: loop {
276-
if let Poll::Ready(maybe_cmd) = this.commands.poll_next_unpin(cx) {
277-
let Some(cmd) = maybe_cmd else { break 'conn };
276+
if let Poll::Ready(Some(cmd)) = this.commands.poll_next_unpin(cx) {
278277
let message = this.on_command(cmd);
279278
let encoded = message.encoded();
280279
trace!(target: "ress::net::connection", peer_id = %this.peer_id, ?message, encoded = alloy_primitives::hex::encode(&encoded), "Sending peer command");

0 commit comments

Comments
 (0)