mirror of
https://github.com/DioxusLabs/dioxus
synced 2024-09-21 06:41:54 +00:00
34 lines
788 B
Rust
34 lines
788 B
Rust
|
use dioxus::prelude::*;
|
||
|
use dioxus_signals::use_signal;
|
||
|
use futures_util::{future, stream, Stream, StreamExt};
|
||
|
use std::time::Duration;
|
||
|
|
||
|
fn main() {
|
||
|
dioxus_desktop::launch(app);
|
||
|
}
|
||
|
|
||
|
fn app(cx: Scope) -> Element {
|
||
|
let count = use_signal(cx, || 10);
|
||
|
|
||
|
use_future(cx, (), |_| async move {
|
||
|
let mut stream = some_stream();
|
||
|
|
||
|
while let Some(second) = stream.next().await {
|
||
|
count.set(second);
|
||
|
}
|
||
|
});
|
||
|
|
||
|
cx.render(rsx! {
|
||
|
h1 { "High-Five counter: {count}" }
|
||
|
})
|
||
|
}
|
||
|
|
||
|
fn some_stream() -> std::pin::Pin<Box<dyn Stream<Item = i32>>> {
|
||
|
Box::pin(
|
||
|
stream::once(future::ready(0)).chain(stream::iter(1..).then(|second| async move {
|
||
|
tokio::time::sleep(Duration::from_secs(1)).await;
|
||
|
second
|
||
|
})),
|
||
|
)
|
||
|
}
|