thaw 0.4.8

An easy to use leptos component library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

mod toast;
mod toast_body;
mod toast_footer;
mod toast_title;
mod toaster;
mod toaster_provider;

pub use toast::*;
pub use toast_body::*;
pub use toast_footer::*;
pub use toast_title::*;
pub use toaster_provider::*;

use leptos::prelude::*;
use std::sync::mpsc::{channel, Receiver, Sender, TryIter};
use wasm_bindgen::UnwrapThrowExt;

#[derive(Clone, Copy)]
pub struct ToasterInjection {
    sender: StoredValue<Sender<ToasterMessage>>,
    trigger: StoredValue<ArcTrigger>,
}

enum ToasterMessage {
    Dispatch(Children, ToastOptions),
    Dismiss(uuid::Uuid),
    DismissAll,
}

impl ToasterInjection {
    #[track_caller]
    pub fn expect_context() -> Self {
        expect_context()
    }

    pub fn channel() -> (Self, ToasterReceiver) {
        let (sender, receiver) = channel::<ToasterMessage>();
        let trigger = ArcTrigger::new();

        (
            Self {
                sender: StoredValue::new(sender),
                trigger: StoredValue::new(trigger.clone()),
            },
            ToasterReceiver::new(receiver, trigger),
        )
    }

    pub fn dismiss_toast(&self, toast_id: uuid::Uuid) {
        self.sender.with_value(|sender| {
            sender
                .send(ToasterMessage::Dismiss(toast_id))
                .unwrap_throw()
        });
        self.trigger.with_value(|trigger| trigger.notify());
    }

    pub fn dismiss_all(&self) {
        self.sender
            .with_value(|sender| sender.send(ToasterMessage::DismissAll).unwrap_throw());
        self.trigger.with_value(|trigger| trigger.notify());
    }

    pub fn dispatch_toast<C, IV>(&self, children: C, options: ToastOptions)
    where
        C: FnOnce() -> IV + Send + 'static,
        IV: IntoView + 'static,
    {
        self.sender.with_value(|sender| {
            sender
                .send(ToasterMessage::Dispatch(
                    Box::new(move || children().into_any()),
                    options,
                ))
                .unwrap_throw()
        });
        self.trigger.with_value(|trigger| trigger.notify());
    }
}

pub struct ToasterReceiver {
    receiver: Receiver<ToasterMessage>,
    trigger: ArcTrigger,
}

impl ToasterReceiver {
    fn new(receiver: Receiver<ToasterMessage>, trigger: ArcTrigger) -> Self {
        Self { receiver, trigger }
    }

    fn try_recv(&self) -> TryIter<'_, ToasterMessage> {
        self.trigger.track();
        self.receiver.try_iter()
    }
}