Searched refs:shelf (Results 1 – 5 of 5) sorted by relevance
98 shelf: Option<Shelf>, field129 shelf: None, in new()205 let mut shelf = state.lock().unwrap().shelf.take().unwrap_or_default(); in spawn_thread() localVariable232 state.shelf = Some(shelf); in spawn_thread()243 f(&mut shelf); in spawn_thread()248 idle_fn(&mut shelf); in spawn_thread()271 let mut shelf = Shelf::default(); in test_shelf() localVariable274 assert_eq!(shelf.put(s), None); in test_shelf()277 assert_eq!(shelf.put(s2), Some("A string".to_string())); in test_shelf()285 assert_eq!(shelf.put(e1), None); in test_shelf()[all …]
59 async_task.queue_hi(move |shelf| { in new_init_with()62 shelf.get_or_put_with(|| GcInternal { in new_init_with()80 self.async_task.queue_lo(|shelf| shelf.get_downcast_mut::<GcInternal>().unwrap().step()) in notify_gc()147 at.queue_lo(move |shelf| { in step()148 shelf.get_downcast_mut::<GcInternal>().unwrap().step() in step()
31 crate::globals::ASYNC_TASK.add_idle(|shelf| { in register_feeder()32 let mut info = shelf.get_mut::<FeederInfo>(); in register_feeder()
161 self.async_task.queue_hi(move |shelf| { in check_state()162 shelf.get_or_put_with(|| LegacyImporterState { in check_state()240 self.async_task.queue_hi(move |shelf| { in do_serialized()247 shelf.get_downcast_mut::<LegacyImporterState>() in do_serialized()258 shelf.remove_downcast_ref::<LegacyImporterState>(); in do_serialized()
404 self.async_task.queue_hi(move |shelf| { in init_shelf()408 shelf.put(AsyncState { legacy_loader, db_path, recently_imported: Default::default() }); in init_shelf()417 self.async_task.queue_hi(move |shelf| { in do_serialized()418 let state = shelf.get_downcast_mut::<AsyncState>().expect("Failed to get shelf."); in do_serialized()