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

example cleanup

Browse source
This commit is contained in:
Maccesch 2023-08-31 18:40:03 +01:00
parent fb9dfc7b76
commit 162432cbfd
1 changed files with 8 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
examples/use_webtransport/src/main.rs
View file

@ -5,12 +5,14 @@ use leptos_use::{use_webtransport_with_options, UseWebTransportOptions};
#[component] #[component]
fn Demo() -> impl IntoView { fn Demo() -> impl IntoView {
let (log, set_log) = create_signal(vec![]); let (datagrams_log, set_datagrams_log) = create_signal(vec![]);
let transport = use_webtransport_with_options( let transport = use_webtransport_with_options(
"https://echo.webtransport.day", "https://echo.webtransport.day",
UseWebTransportOptions::default() UseWebTransportOptions::default()
.on_error(|e| set_log.update(|log| log.push(format!("Error: {:?}", e)))), .on_open(|_| set_datagrams_log.update(|log| log.push("Connection opened".to_string())))
.on_close(|_| set_datagrams_log.update(|log| log.push("Connection closed".to_string())))
.on_error(|e| set_datagrams_log.update(|log| log.push(format!("Error: {:?}", e)))),
); );
let (text, set_text) = create_signal("".to_string()); let (text, set_text) = create_signal("".to_string());
@ -19,37 +21,17 @@ fn Demo() -> impl IntoView {
let transport = transport.clone(); let transport = transport.clone();
move |e| { move |e| {
set_log.update(|log| log.push(format!("Sent datagram: '{}'", text()))); set_datagrams_log.update(|log| log.push(format!("Sent datagram: '{}'", text())));
transport.send_datagrams(text().as_bytes()); transport.send_datagrams(text().as_bytes());
} }
}; };
let ready_state = transport.ready_state;
let _ = watch(
ready_state,
move |ready, prev_ready, _| {
if ready == &ConnectionReadyState::Open
&& prev_ready.unwrap_or(&ConnectionReadyState::Closed)
!= &ConnectionReadyState::Open
{
set_log.update(|log| log.push("Connection opened".to_string()));
} else if ready == &ConnectionReadyState::Closed
&& prev_ready.unwrap_or(&ConnectionReadyState::Open)
!= &ConnectionReadyState::Closed
{
set_log.update(|log| log.push("Connection closed".to_string()));
}
},
false,
);
let _ = watch( let _ = watch(
transport.datagrams, transport.datagrams,
move |grams, _, _| { move |grams, _, _| {
if let Some(grams) = grams { if let Some(grams) = grams {
set_log.update(|log| { set_datagrams_log.update(|log| {
log.push(format!( log.push(format!(
"Received datagrams: '{}'", "Received datagrams: '{}'",
String::from_utf8(grams.clone()).expect("valid utf8") String::from_utf8(grams.clone()).expect("valid utf8")
@ -60,6 +42,8 @@ fn Demo() -> impl IntoView {
false, false,
); );
let ready_state = transport.ready_state;
view! { view! {
<h2>Datagrams</h2> <h2>Datagrams</h2>
<textarea on:change=move |e| set_text(event_target_value(&e))/> <textarea on:change=move |e| set_text(event_target_value(&e))/>