This commit is contained in:
parent
6709a96285
commit
824d4957cd
@ -4370,16 +4370,22 @@ mod document_files {
|
|||||||
MsgAction::Show,
|
MsgAction::Show,
|
||||||
MsgAction::Update(Update::new()),
|
MsgAction::Update(Update::new()),
|
||||||
];
|
];
|
||||||
|
let mut msgs: HashMap<Uuid, MsgAction> = HashMap::new();
|
||||||
for msg_action in msg_actions.iter() {
|
for msg_action in msg_actions.iter() {
|
||||||
let msg = Message::new(alt.clone(), msg_action.clone());
|
let msg = Message::new(alt.clone(), msg_action.clone());
|
||||||
|
msgs.insert(msg.get_message_id().clone(), msg_action.clone());
|
||||||
queue.send(msg).unwrap();
|
queue.send(msg).unwrap();
|
||||||
match test_doc.get_receiver().recv_timeout(TIMEOUT) {
|
}
|
||||||
Ok(msg) => unreachable!("for {:?} should not receive: {:?}", msg_action, msg),
|
match test_doc.get_receiver().recv_timeout(TIMEOUT) {
|
||||||
Err(err) => match err {
|
Ok(msg) => unreachable!(
|
||||||
RecvTimeoutError::Timeout => {}
|
"for {:?} should not receive: {:?}",
|
||||||
_ => unreachable!("should have timed out"),
|
msgs.get(msg.get_message_id()).unwrap(),
|
||||||
},
|
msg
|
||||||
}
|
),
|
||||||
|
Err(err) => match err {
|
||||||
|
RecvTimeoutError::Timeout => {}
|
||||||
|
_ => unreachable!("got {:?}, should have timed out", err),
|
||||||
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user