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 …]
58 async_task.queue_hi(move |shelf| { in new_init_with()61 shelf.get_or_put_with(|| GcInternal { in new_init_with()79 self.async_task.queue_lo(|shelf| shelf.get_downcast_mut::<GcInternal>().unwrap().step()) in notify_gc()145 at.queue_lo(move |shelf| { in step()146 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()
159 self.async_task.queue_hi(move |shelf| { in check_state()160 shelf.get_or_put_with(|| LegacyMigratorState { in check_state()239 self.async_task.queue_hi(move |shelf| { in do_serialized()246 shelf.get_downcast_mut::<LegacyMigratorState>() in do_serialized()257 shelf.remove_downcast_ref::<LegacyMigratorState>(); in do_serialized()
393 self.async_task.queue_hi(move |shelf| { in init_shelf()397 shelf.put(AsyncState { legacy_loader, db_path, recently_imported: Default::default() }); in init_shelf()406 self.async_task.queue_hi(move |shelf| { in do_serialized()407 let state = shelf.get_downcast_mut::<AsyncState>().expect("Failed to get shelf."); in do_serialized()