Skip to content

Commit e60addf

Browse files
committed
Exit sv1 mining device if channel drops
.. otherwise it can go into an endless loop(which surprisingly did not happen until now..)
1 parent 4ba1d86 commit e60addf

File tree

1 file changed

+2
-1
lines changed
  • roles/test-utils/mining-device-sv1/src

1 file changed

+2
-1
lines changed

roles/test-utils/mining-device-sv1/src/client.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,8 @@ impl Client {
244244
if let Ok(incoming) = recv_incoming.clone().recv().await {
245245
Self::parse_message(client.clone(), Ok(incoming)).await;
246246
} else {
247-
warn!("Error reading from socket via `recv_incoming` channel")
247+
warn!("Error reading from socket via `recv_incoming` channel");
248+
break;
248249
}
249250
}
250251
}

0 commit comments

Comments
 (0)