diff --git a/src/derived.rs b/src/derived.rs index e6feef8..597ed97 100644 --- a/src/derived.rs +++ b/src/derived.rs @@ -786,7 +786,8 @@ where key, input ) - }).next() + }) + .next() .is_some(); // Either way, we have to update our entry. diff --git a/tests/parallel/true_parallel.rs b/tests/parallel/true_parallel.rs index 27c4f8e..451ea9e 100644 --- a/tests/parallel/true_parallel.rs +++ b/tests/parallel/true_parallel.rs @@ -96,7 +96,7 @@ fn true_parallel_propagate_panic() { // `thread1` will wait_for a barrier in the start of `sum`. Once it can // continue, it will panic. let thread1 = std::thread::spawn({ - let db = db.fork(); + let db = db.snapshot(); move || { let v = db.knobs().sum_signal_on_entry.with_value(1, || { db.knobs().sum_wait_for_on_exit.with_value(2, || { @@ -110,7 +110,7 @@ fn true_parallel_propagate_panic() { // `thread2` will wait until `thread1` has entered sum and then -- once it // has set itself to block -- signal `thread1` to continue. let thread2 = std::thread::spawn({ - let db = db.fork(); + let db = db.snapshot(); move || { db.knobs().signal.wait_for(1); db.knobs().signal_on_will_block.set(2);