Remove double loop
This double loop appears to be accidental.
@@ -131,7 +131,6 @@ where
let join_handle = std::thread::Builder::new()
.name(thread_name)
.spawn(move || loop {
- loop {
let (message_type, message_bytes, source_id) = match rx.receiver.recv() {
Ok(DispatchMessage::Message {
message_type,
@@ -151,7 +150,6 @@ where
Ok(_) => (),
Err(err) => warn!("Unable to dispatch message: {:?}", err),
}
- }
});
match join_handle {
