diff options
Diffstat (limited to 'engine/src/asset.rs')
| -rw-r--r-- | engine/src/asset.rs | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/engine/src/asset.rs b/engine/src/asset.rs index 76d664a..ebcf5c7 100644 --- a/engine/src/asset.rs +++ b/engine/src/asset.rs @@ -860,6 +860,10 @@ impl crate::ecs::extension::Extension for Extension fn add_received_assets(mut assets: Single<Assets>) { + let Ok(assets) = assets.get_mut() else { + unreachable!(); + }; + let Events { curr_tick_events, last_tick_events } = &mut assets.events; std::mem::swap(last_tick_events, curr_tick_events); @@ -869,7 +873,7 @@ fn add_received_assets(mut assets: Single<Assets>) while let Some(import_work_msg) = assets.import_work_msg_receiver.try_recv().ok() { match import_work_msg { ImportWorkMessage::Store { do_store, label, asset } => { - do_store(&mut assets, label, asset); + do_store(assets, label, asset); } ImportWorkMessage::Load { do_load, label, asset_settings } => { do_load( @@ -887,6 +891,10 @@ fn add_received_assets(mut assets: Single<Assets>) fn check_import_wq_thread_not_panicked(assets: Single<Assets>, mut actions: Actions<'_>) { + let Ok(assets) = assets.get() else { + unreachable!(); + }; + if assets.import_work_queue.get_thread_panic().is_some() { cold_path(); |