Have clock send out on_update message.
Some checks failed
Gitea Actions Demo / Explore-Gitea-Actions (push) Failing after 2s
Some checks failed
Gitea Actions Demo / Explore-Gitea-Actions (push) Failing after 2s
This commit is contained in:
parent
18e33f78c2
commit
3e5062d7d8
@ -6616,13 +6616,6 @@ mod document_files {
|
|||||||
MsgAction::OnUpdate(Records::new(Names::new())),
|
MsgAction::OnUpdate(Records::new(Names::new())),
|
||||||
);
|
);
|
||||||
queue.send(trigger.clone()).unwrap();
|
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);
|
sleep(TIMEOUT);
|
||||||
let msg = Message::new(doc_name, Query::new());
|
let msg = Message::new(doc_name, Query::new());
|
||||||
queue.send(msg.clone()).unwrap();
|
queue.send(msg.clone()).unwrap();
|
||||||
@ -6799,7 +6792,7 @@ impl Clock {
|
|||||||
loop {
|
loop {
|
||||||
self.queue.send(Message::new(
|
self.queue.send(Message::new(
|
||||||
Name::english("clock"),
|
Name::english("clock"),
|
||||||
Records::new(Names::new()),
|
MsgAction::OnUpdate(Records::new(Names::new())),
|
||||||
));
|
));
|
||||||
sleep(Duration::from_secs(1));
|
sleep(Duration::from_secs(1));
|
||||||
}
|
}
|
||||||
@ -6853,7 +6846,7 @@ mod clocks {
|
|||||||
}
|
}
|
||||||
let action = msg.get_action();
|
let action = msg.get_action();
|
||||||
match 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),
|
_ => unreachable!("got {:?}, should have been empty record", action),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user