Wait for msg arriving in test

crates/core/src/dht/chord.rs

@@ -285,12 +285,10 @@ impl Chord<PeerRingAction> for PeerRing {
 
         let succ = {
             if successor.is_empty()? || self.bias(did) <= self.bias(successor.min()?) {
-                println!("===> 1");
                 // If the did is closer to self than successor, return successor as the
                 // successor of that did.
                 Ok(PeerRingAction::Some(successor.min()?))
             } else {
-                println!("===> 2");
                 // Otherwise, find the closest preceding node and ask it to find the successor.
                 let closest_predecessor = finger.closest_predecessor(did);
                 Ok(PeerRingAction::RemoteAction(

crates/node/src/processor.rs

@@ -482,6 +482,7 @@ mod test {
         let uuid2 = p2.send_message(did1, test_text2.as_bytes()).await.unwrap();
         println!("send_message 2 done, msg id: {}", uuid2);
 
+        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
         println!("check received");
 
         let mut msgs2 = callback2.msgs.try_lock().unwrap();