diff --git a/src/message.rs b/src/message.rs index 7bd6f33..e4fe619 100644 --- a/src/message.rs +++ b/src/message.rs @@ -6616,13 +6616,6 @@ mod document_files { MsgAction::OnUpdate(Records::new(Names::new())), ); queue.send(trigger.clone()).unwrap(); - let trigger_reply = doc.get_receiver().recv_timeout(TIMEOUT).unwrap(); - assert_eq!( - trigger_reply.get_message_id(), - trigger.get_message_id(), - "msg {:?} had incorrect message id", - trigger_reply - ); sleep(TIMEOUT); let msg = Message::new(doc_name, Query::new()); queue.send(msg.clone()).unwrap(); @@ -6799,7 +6792,7 @@ impl Clock { loop { self.queue.send(Message::new( Name::english("clock"), - Records::new(Names::new()), + MsgAction::OnUpdate(Records::new(Names::new())), )); sleep(Duration::from_secs(1)); } @@ -6853,7 +6846,7 @@ mod clocks { } let action = msg.get_action(); match action { - MsgAction::Records(result) => assert_eq!(result.len(), 0), + MsgAction::OnUpdate(result) => assert_eq!(result.len(), 0), _ => unreachable!("got {:?}, should have been empty record", action), } }