hobo 0.4.0

hobo is a Rust frontend framework
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

use discard::DiscardOnDrop;
use futures_signals::{
	signal::{Signal, SignalExt},
	signal_map::{MapDiff, SignalMap, SignalMapExt},
	signal_vec::{SignalVec, SignalVecExt, VecDiff},
	CancelableFutureHandle,
};
use wasm_bindgen_futures::spawn_local as spawn;

pub trait SignalExt2: Signal {
	fn subscribe<F>(self, callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(Self::Item) + 'static,
		Self: Sized;

	// fn spawn(self) -> DiscardOnDrop<CancelableFutureHandle> where
	//     Self: Sized;
}

impl<T: Signal + 'static> SignalExt2 for T {
	fn subscribe<F>(self, mut callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(Self::Item) + 'static,
		Self: Sized,
	{
		let (handle, fut) = futures_signals::cancelable_future(self.for_each(move |x| { callback(x); std::future::ready(()) }), Default::default);
		spawn(fut);
		handle
	}

	// fn spawn(self) -> DiscardOnDrop<CancelableFutureHandle> where
	//     Self: Sized,
	// {
	//     let (handle, fut) = futures_signals::cancelable_future(self.for_each(move |_| std::future::ready(())), Default::default);
	//     spawn(fut);
	//     handle
	// }
}

pub trait SignalMapExt2: SignalMap {
	fn subscribe<F>(self, callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(MapDiff<Self::Key, Self::Value>) + 'static,
		Self: Sized;
}

impl<T: SignalMap + 'static> SignalMapExt2 for T {
	fn subscribe<F>(self, mut callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(MapDiff<Self::Key, Self::Value>) + 'static,
		Self: Sized,
	{
		let (handle, fut) = futures_signals::cancelable_future(self.for_each(move |x| { callback(x); std::future::ready(()) }), Default::default);
		spawn(fut);
		handle
	}
}

pub trait SignalVecExt2: SignalVec {
	fn subscribe<F>(self, callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(VecDiff<Self::Item>) + 'static,
		Self: Sized;
}

impl<T: SignalVec + 'static> SignalVecExt2 for T {
	fn subscribe<F>(self, mut callback: F) -> DiscardOnDrop<CancelableFutureHandle> where
		F: FnMut(VecDiff<Self::Item>) + 'static,
		Self: Sized,
	{
		let (handle, fut) = futures_signals::cancelable_future(self.for_each(move |x| { callback(x); std::future::ready(()) }), Default::default);
		spawn(fut);
		handle
	}
}