Pull out asset handler refactor from https://github.com/DioxusLabs/dioxus/pull/2972 (#3000)
This commit is contained in:
1 parent
95976d9a17
commit
f9c2f740c2
4 files changed
+15
-28
No files matched your search
@@ -1,4 +1,4 @@
|
|||||||
use dioxus_core::prelude::{Runtime, ScopeId};
|
use dioxus_core::prelude::Callback;
|
||||||
use rustc_hash::FxHashMap;
|
use rustc_hash::FxHashMap;
|
||||||
use std::{cell::RefCell, rc::Rc};
|
use std::{cell::RefCell, rc::Rc};
|
||||||
use wry::{http::Request, RequestAsyncResponder};
|
use wry::{http::Request, RequestAsyncResponder};
|
||||||
@@ -7,20 +7,17 @@ use wry::{http::Request, RequestAsyncResponder};
|
|||||||
pub type AssetRequest = Request<Vec<u8>>;
|
pub type AssetRequest = Request<Vec<u8>>;
|
||||||
|
|
||||||
pub struct AssetHandler {
|
pub struct AssetHandler {
|
||||||
f: Box<dyn Fn(AssetRequest, RequestAsyncResponder) + 'static>,
|
f: Callback<(AssetRequest, RequestAsyncResponder)>,
|
||||||
scope: ScopeId,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Clone)]
|
#[derive(Clone)]
|
||||||
pub struct AssetHandlerRegistry {
|
pub struct AssetHandlerRegistry {
|
||||||
dom_rt: Rc<Runtime>,
|
|
||||||
handlers: Rc<RefCell<FxHashMap<String, AssetHandler>>>,
|
handlers: Rc<RefCell<FxHashMap<String, AssetHandler>>>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl AssetHandlerRegistry {
|
impl AssetHandlerRegistry {
|
||||||
pub fn new(dom_rt: Rc<Runtime>) -> Self {
|
pub fn new() -> Self {
|
||||||
AssetHandlerRegistry {
|
AssetHandlerRegistry {
|
||||||
dom_rt,
|
|
||||||
handlers: Default::default(),
|
handlers: Default::default(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -37,20 +34,16 @@ impl AssetHandlerRegistry {
|
|||||||
) {
|
) {
|
||||||
if let Some(handler) = self.handlers.borrow().get(name) {
|
if let Some(handler) = self.handlers.borrow().get(name) {
|
||||||
// And run the handler in the scope of the component that created it
|
// And run the handler in the scope of the component that created it
|
||||||
self.dom_rt
|
handler.f.call((request, responder));
|
||||||
.on_scope(handler.scope, || (handler.f)(request, responder));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn register_handler(
|
pub fn register_handler(
|
||||||
&self,
|
&self,
|
||||||
name: String,
|
name: String,
|
||||||
f: Box<dyn Fn(AssetRequest, RequestAsyncResponder) + 'static>,
|
f: Callback<(AssetRequest, RequestAsyncResponder)>,
|
||||||
scope: ScopeId,
|
|
||||||
) {
|
) {
|
||||||
self.handlers
|
self.handlers.borrow_mut().insert(name, AssetHandler { f });
|
||||||
.borrow_mut()
|
|
||||||
.insert(name, AssetHandler { f, scope });
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn remove_handler(&self, name: &str) -> Option<AssetHandler> {
|
pub fn remove_handler(&self, name: &str) -> Option<AssetHandler> {
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ use crate::{
|
|||||||
AssetRequest, Config, WryEventHandler,
|
AssetRequest, Config, WryEventHandler,
|
||||||
};
|
};
|
||||||
use dioxus_core::{
|
use dioxus_core::{
|
||||||
prelude::{current_scope_id, ScopeId},
|
prelude::{Callback, ScopeId},
|
||||||
VirtualDom,
|
VirtualDom,
|
||||||
};
|
};
|
||||||
use std::rc::{Rc, Weak};
|
use std::rc::{Rc, Weak};
|
||||||
@@ -236,14 +236,10 @@ impl DesktopService {
|
|||||||
pub fn register_asset_handler(
|
pub fn register_asset_handler(
|
||||||
&self,
|
&self,
|
||||||
name: String,
|
name: String,
|
||||||
handler: Box<dyn Fn(AssetRequest, RequestAsyncResponder) + 'static>,
|
handler: impl Fn(AssetRequest, RequestAsyncResponder) + 'static,
|
||||||
scope: Option<ScopeId>,
|
|
||||||
) {
|
) {
|
||||||
self.asset_handlers.register_handler(
|
self.asset_handlers
|
||||||
name,
|
.register_handler(name, Callback::new(move |(req, resp)| handler(req, resp)))
|
||||||
handler,
|
|
||||||
scope.unwrap_or(current_scope_id().unwrap_or(ScopeId(0))),
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Removes an asset handler by its identifier.
|
/// Removes an asset handler by its identifier.
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ use crate::{
|
|||||||
ShortcutHandle, ShortcutRegistryError, WryEventHandler,
|
ShortcutHandle, ShortcutRegistryError, WryEventHandler,
|
||||||
};
|
};
|
||||||
use dioxus_core::{
|
use dioxus_core::{
|
||||||
prelude::{consume_context, current_scope_id, use_hook_with_cleanup, RuntimeGuard},
|
prelude::{consume_context, use_hook_with_cleanup, RuntimeGuard},
|
||||||
use_hook, Runtime,
|
use_hook, Runtime,
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -69,11 +69,9 @@ pub fn use_asset_handler(
|
|||||||
|
|
||||||
use_hook_with_cleanup(
|
use_hook_with_cleanup(
|
||||||
|| {
|
|| {
|
||||||
crate::window().asset_handlers.register_handler(
|
crate::window()
|
||||||
name.to_string(),
|
.asset_handlers
|
||||||
Box::new(move |asset, responder| cb((asset, responder))),
|
.register_handler(name.to_string(), cb);
|
||||||
current_scope_id().unwrap(),
|
|
||||||
);
|
|
||||||
|
|
||||||
Rc::new(name.to_string())
|
Rc::new(name.to_string())
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -188,7 +188,7 @@ impl WebviewInstance {
|
|||||||
|
|
||||||
let mut web_context = WebContext::new(cfg.data_dir.clone());
|
let mut web_context = WebContext::new(cfg.data_dir.clone());
|
||||||
let edit_queue = WryQueue::default();
|
let edit_queue = WryQueue::default();
|
||||||
let asset_handlers = AssetHandlerRegistry::new(dom.runtime());
|
let asset_handlers = AssetHandlerRegistry::new();
|
||||||
let edits = WebviewEdits::new(dom.runtime(), edit_queue.clone());
|
let edits = WebviewEdits::new(dom.runtime(), edit_queue.clone());
|
||||||
let file_hover = NativeFileHover::default();
|
let file_hover = NativeFileHover::default();
|
||||||
let headless = !cfg.window.window.visible;
|
let headless = !cfg.window.window.visible;
|
||||||
|
|||||||
Reference in new issue
Block a user