test

Signed-off-by: TXXT <[email protected]>

Author: hunterlxt

src/lib.rs

@@ -723,9 +723,9 @@ pub fn list() -> Vec<(String, String)> {
 #[doc(hidden)]
 pub fn eval<R, F: FnOnce(Option<String>) -> R>(name: &str, f: F) -> Option<R> {
     let id = thread::current().id();
-    let group = REGISTRY_GROUP.read().unwrap();
 
     let p = {
+        let group = REGISTRY_GROUP.read().unwrap();
         let registry = group
             .get(&id)
             .unwrap_or(&REGISTRY_GLOBAL.registry)

tests/tests.rs

@@ -36,13 +36,13 @@ fn test_pause() {
     });
 
     rx_before.recv().unwrap();
-    assert!(rx.recv_timeout(Duration::from_millis(10000)).is_err());
+    assert!(rx.recv_timeout(Duration::from_millis(10)).is_err());
     println!("..................");
     fail::cfg("pause", "pause").unwrap();
     rx.recv_timeout(Duration::from_millis(300)).unwrap();
 
     rx_before.recv().unwrap();
-    assert!(rx.recv_timeout(Duration::from_millis(10000)).is_err());
+    assert!(rx.recv_timeout(Duration::from_millis(10)).is_err());
     fail::remove("pause");
 
     rx.recv_timeout(Duration::from_millis(300)).unwrap();