Compare commits

...

2 Commits

Author SHA1 Message Date
Thorsten Ball
de855fa4a7 Make debug actually do debug 2024-07-17 16:48:21 +02:00
Thorsten Ball
46239b7a04 debug: Debug a flaky test 2024-07-17 16:38:13 +02:00

View File

@@ -376,11 +376,12 @@ mod tests {
#[test]
fn test_event_stream_simple() {
for _ in 0..3 {
for iteration in 0..3 {
let dir = tempfile::Builder::new()
.prefix("test-event-stream")
.tempdir()
.unwrap();
println!("iteration: {}, dir: {:?}", iteration, dir);
let path = dir.path().canonicalize().unwrap();
for i in 0..10 {
fs::write(path.join(format!("existing-file-{}", i)), "").unwrap();
@@ -389,17 +390,33 @@ mod tests {
let (tx, rx) = mpsc::channel();
let (stream, handle) = EventStream::new(&[&path], Duration::from_millis(50));
thread::spawn(move || stream.run(move |events| tx.send(events.to_vec()).is_ok()));
thread::spawn(move || {
stream.run(move |events| {
println!("sending events:");
for event in events.iter() {
println!("- {:?}", event);
}
tx.send(events.to_vec()).is_ok()
})
});
println!("--------- creating new file");
fs::write(path.join("new-file"), "").unwrap();
let events = rx.recv_timeout(Duration::from_secs(2)).unwrap();
let event = events.last().unwrap();
assert_eq!(event.path, path.join("new-file"));
assert!(event.flags.contains(StreamFlags::ITEM_CREATED));
println!("---------- removing existing file");
fs::remove_file(path.join("existing-file-5")).unwrap();
let events = rx.recv_timeout(Duration::from_secs(2)).unwrap();
let event = events.last().unwrap();
// thread 'tests::test_event_stream_simple' panicked at crates/fsevent/src/fsevent.rs:403:13:
// assertion `left == right` failed
// left: "/private/var/folders/cf/sdy1nn_542g798vjgnxxz8140000gn/T/test-event-streamW1SkQ2/new-file"
// right: "/private/var/folders/cf/sdy1nn_542g798vjgnxxz8140000gn/T/test-event-streamW1SkQ2/existing-file-5"
assert_eq!(event.path, path.join("existing-file-5"));
assert!(event.flags.contains(StreamFlags::ITEM_REMOVED));
drop(handle);