From 3fd6bafd33c3101b8e5fb2b367f2a27dd780de6e Mon Sep 17 00:00:00 2001 From: Jeff Baskin Date: Thu, 16 Oct 2025 08:41:43 -0400 Subject: [PATCH] Readded multiple additions test. --- src/message.rs | 25 +------------------------ 1 file changed, 1 insertion(+), 24 deletions(-) diff --git a/src/message.rs b/src/message.rs index 78ca5b0..c59f9a9 100644 --- a/src/message.rs +++ b/src/message.rs @@ -4696,35 +4696,12 @@ mod document_files { _ => unreachable!("got {:?}, should have been integer", holder), }; assert!(entries.contains(&data), "did not find {:?} in {:?}", data, entries); - enties.remove(&data); + entries.remove(&data); } } _ => unreachable!("\n\ngot {:?}\n\nshould have been records", action), } assert!(entries.is_empty(), "did not use {:?}", entries); - /* - let count = 4; - let mut docdef = DocDef::new(); - let name = "field"; - let doc_name = "document"; - let data = Uuid::new_v4(); - docdef.add_field(name.to_string(), FieldType::Uuid); - let (queue, rx) = test_doc(doc_name, docdef, standard_routes()); - let mut new_doc = Addition::new(); - new_doc.add_field(name.to_string(), data.clone()); - for _ in 0..count { - let msg = Message::new(doc_name, new_doc.clone()); - queue.send(msg.clone()).unwrap(); - rx.recv_timeout(TIMEOUT).unwrap(); // eats the confirmation reply. - } - let msg = Message::new(doc_name, Query::new()); - queue.send(msg).unwrap(); - let result = rx.recv_timeout(TIMEOUT).unwrap(); - match result.get_action() { - MsgAction::Reply(data) => assert_eq!(data.len(), count), - _ => unreachable!("got {:?}: should have been a reply", result.get_action()), - } - */ } /*