72             .unwrap()  in get_mut()
85             .unwrap()  in get_or_put_with()
163         let mut state = state.lock().unwrap();  in add_idle()
172         let mut state = state.lock().unwrap();  in queue()
205             let mut shelf = state.lock().unwrap().shelf.take().unwrap_or_default();  in spawn_thread()
208                     let state = state.lock().unwrap();  in spawn_thread()
218                             .unwrap();  in spawn_thread()
288         let s3 = shelf.get_downcast_ref::<String>().unwrap();  in test_shelf()
293             let e2 = shelf.get_downcast_mut::<Elf>().unwrap();  in test_shelf()
299         let e3 = shelf.remove_downcast_ref::<Elf>().unwrap();  in test_shelf()
310         let i2 = shelf.get_downcast_ref::<u64>().unwrap();  in test_shelf()
327             start_receiver.recv().unwrap();  in test_async_task()
349             let trace = shelf.get_downcast_ref::<Vec<String>>().unwrap();  in test_async_task()
350             trace_sender.send(trace.clone()).unwrap();  in test_async_task()
354         start_sender.send(()).unwrap();  in test_async_task()
355         let trace = trace_receiver.recv().unwrap();  in test_async_task()
369                 sender.send(()).unwrap();  in test_async_task_chain()
372         receiver.recv().unwrap();  in test_async_task_chain()
385             done_sender.send(()).unwrap();  in test_async_task_panic()
387         done_receiver.recv().unwrap();  in test_async_task_panic()
396             idle_done_sender.send(()).unwrap();  in test_async_task_idle()
411             done_sender.send(()).unwrap();  in test_async_task_idle()
419         done_receiver.recv().unwrap();  in test_async_task_idle()
420         idle_done_receiver.recv_timeout(Duration::from_millis(1)).unwrap();  in test_async_task_idle()
432             done_sender.send(()).unwrap();  in test_async_task_idle()
440         done_receiver.recv().unwrap();  in test_async_task_idle()
441         idle_done_receiver.recv_timeout(Duration::from_millis(1)).unwrap();  in test_async_task_idle()
457                 idle_sender.send(i).unwrap();  in test_async_task_multiple_idle()
488             idle_sender.send(*i).unwrap();  in test_async_task_idle_queues_job()
500         assert_eq!(0, idle_receiver.recv_timeout(Duration::from_millis(200)).unwrap());  in test_async_task_idle_queues_job()
505         assert_eq!(1, idle_receiver.recv_timeout(Duration::from_millis(100)).unwrap());  in test_async_task_idle_queues_job()
506         assert_eq!(2, idle_receiver.recv_timeout(Duration::from_millis(100)).unwrap());  in test_async_task_idle_queues_job()
507         assert_eq!(3, idle_receiver.recv_timeout(Duration::from_millis(100)).unwrap());  in test_async_task_idle_queues_job()
517             idle_sender.send(()).unwrap();  in test_async_task_idle_panic()
522         idle_receiver.recv().unwrap();  in test_async_task_idle_panic()
528             done_sender.send(()).unwrap();  in test_async_task_idle_panic()
530         done_receiver.recv().unwrap();  in test_async_task_idle_panic()