adam/leptos-use
1
0
Fork 0
mirror of https://github.com/adoyle0/leptos-use.git synced 2025-02-02 10:54:15 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

post merge cleanup

Browse source
This commit is contained in:
Maccesch 2024-07-22 23:20:35 +01:00
parent ec6027c59e
commit b4a0efcc06
5 changed files with 11 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/is_err.rs
View file

@ -1,4 +1,3 @@
use crate::utils::use_derive_signal;
use leptos::prelude::*;
crate::use_derive_signal!(

5
src/use_mutation_observer.rs
View file

@ -1,13 +1,12 @@
use crate::core::ElementsMaybeSignal;
use cfg_if::cfg_if;
use default_struct_builder::DefaultBuilder;
use leptos::prelude::diagnostics::SpecialNonReactiveZone;
use leptos::prelude::wrappers::read::Signal;
use leptos::prelude::*;
use wasm_bindgen::prelude::*;
cfg_if! { if #[cfg(not(feature = "ssr"))] {
use crate::use_supported;
use leptos::prelude::*;
use std::cell::RefCell;
use std::rc::Rc;
}}
@ -90,7 +89,7 @@ where
let closure_js = Closure::<dyn FnMut(js_sys::Array, web_sys::MutationObserver)>::new(
move |entries: js_sys::Array, observer| {
#[cfg(debug_assertions)]
let _z = SpecialNonReactiveZone::enter();
let _z = leptos::prelude::diagnostics::SpecialNonReactiveZone::enter();
callback(
entries

5
src/use_resize_observer.rs
View file

@ -1,15 +1,14 @@
use crate::core::ElementsMaybeSignal;
use cfg_if::cfg_if;
use default_struct_builder::DefaultBuilder;
use leptos::prelude::diagnostics::SpecialNonReactiveZone;
use leptos::prelude::wrappers::read::Signal;
use leptos::prelude::*;
cfg_if! { if #[cfg(not(feature = "ssr"))] {
use crate::use_supported;
use std::cell::RefCell;
use std::rc::Rc;
use wasm_bindgen::prelude::*;
use leptos::prelude::*;
}}
/// Reports changes to the dimensions of an Element's content or the border-box.
@ -92,7 +91,7 @@ where
let closure_js = Closure::<dyn FnMut(js_sys::Array, web_sys::ResizeObserver)>::new(
move |entries: js_sys::Array, observer| {
#[cfg(debug_assertions)]
let _z = SpecialNonReactiveZone::enter();
let _z = leptos::prelude::diagnostics::SpecialNonReactiveZone::enter();
callback(
entries

8
src/use_user_media.rs
View file

@ -1,7 +1,7 @@
use crate::core::MaybeRwSignal;
use cfg_if::cfg_if;
use default_struct_builder::DefaultBuilder;
use leptos::*;
use leptos::prelude::*;
use wasm_bindgen::{JsCast, JsValue};
/// Reactive [`mediaDevices.getUserMedia`](https://developer.mozilla.org/en-US/docs/Web/API/MediaDevices/getUserMedia) streaming.
@ -59,7 +59,7 @@ pub fn use_user_media_with_options(
let (enabled, set_enabled) = enabled.into_signal();
let (stream, set_stream) = create_signal(None::<Result<web_sys::MediaStream, JsValue>>);
let (stream, set_stream) = signal(None::<Result<web_sys::MediaStream, JsValue>>);
let _start = move || async move {
cfg_if! { if #[cfg(not(feature = "ssr"))] {
@ -88,7 +88,7 @@ pub fn use_user_media_with_options(
let start = move || {
cfg_if! { if #[cfg(not(feature = "ssr"))] {
spawn_local(async move {
leptos::spawn::spawn_local(async move {
_start().await;
stream.with_untracked(move |stream| {
if let Some(Ok(_)) = stream {
@ -108,7 +108,7 @@ pub fn use_user_media_with_options(
move || enabled.get(),
move |enabled, _, _| {
if *enabled {
spawn_local(async move {
leptos::spawn::spawn_local(async move {
_start().await;
});
} else {

6
src/use_websocket.rs
View file

@ -548,7 +548,7 @@ where
};
let send = {
let on_error = Rc::clone(&on_error);
let on_error = Arc::clone(&on_error);
move |value: &T| {
if C::is_binary() {
@ -670,7 +670,7 @@ impl<T: ?Sized, E, D> UseWebSocketOptions<T, E, D> {
F: Fn(UseWebSocketError<E, D>) + 'static,
{
Self {
on_error: Rc::new(handler),
on_error: Arc::new(handler),
..self
}
}
@ -681,7 +681,7 @@ impl<T: ?Sized, E, D> UseWebSocketOptions<T, E, D> {
F: Fn(&T) + 'static,
{
Self {
on_message: Rc::new(handler),
on_message: Arc::new(handler),
..self
}
}