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
#[test]
fn resource_returns_last_future() {
#[cfg(feature = "ssr")]
{
use futures::{channel::oneshot::channel, FutureExt};
use leptos_reactive::{
create_resource, create_runtime, create_signal, SignalGet,
SignalSet,
};
use tokio::task;
use tokio_test::block_on;
let runtime = create_runtime();
block_on(task::LocalSet::new().run_until(async move {
task::spawn_local(async move {
// Set up a resource that can listen to two different futures that we can resolve independently
let (tx_1, rx_1) = channel::<()>();
let (tx_2, rx_2) = channel::<()>();
let rx_1 = rx_1.shared();
let rx_2 = rx_2.shared();
let (channel_number, set_channel_number) = create_signal(1);
let resource = create_resource(
move || channel_number.get(),
move |channel_number| {
let rx_1 = rx_1.clone();
let rx_2 = rx_2.clone();
async move {
match channel_number {
1 => rx_1.await,
2 => rx_2.await,
_ => unreachable!(),
}
.unwrap();
channel_number
}
},
);
// Switch to waiting to second future while first is still loading
set_channel_number.set(2);
// Resolve first future
tx_1.send(()).unwrap();
task::yield_now().await;
// Resource should still be loading
assert_eq!(resource.get(), None);
// Resolve second future
tx_2.send(()).unwrap();
task::yield_now().await;
// Resource should now be loaded
assert_eq!(resource.get(), Some(2));
})
.await
.unwrap();
}));
runtime.dispose();
}
}