feat(examples): updated examples

Signed-off-by: Jad K. Haddad <jadkhaddad@gmail.com>

Author: JadKHaddad

cspell.json

@@ -2,9 +2,12 @@
     "version": "0.2",
     "language": "en",
     "words": [
+        "ashx",
+        "Chilkat",
         "clippy",
         "codegen",
         "crossbario",
+        "dhcpv",
         "docsrs",
         "fastwebsockets",
         "framez",
@@ -20,9 +23,13 @@
         "rngs",
         "rustdoc",
         "Seedable",
+        "smoltcp",
         "Swatinem",
         "taiki",
         "thiserror",
+        "timg",
+        "trng",
+        "uninit",
         "websocketz",
         "WSSERVER",
         "wstest",

examples/autobahn-client.rs

@@ -1,3 +1,9 @@
+//! Run with
+//!
+//! ```not_rust
+//! cargo run --example autobahn-client
+//! ```
+
 use embedded_io_adapters::tokio_1::FromTokio;
 use rand::{SeedableRng, rngs::StdRng};
 use tokio::net::TcpStream;
@@ -96,7 +102,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                     _ => {}
                 },
                 Err(err) => {
-                    println!("Error reading message: {err}");
+                    eprintln!("Error reading message: {err}");
 
                     send!(websocketz, Message::Close(None))?;
 

examples/autobahn-server.rs

@@ -1,3 +1,9 @@
+//! Run with
+//!
+//! ```not_rust
+//! cargo run --example autobahn-server
+//! ```
+
 use embedded_io_adapters::tokio_1::FromTokio;
 use rand::{SeedableRng, rngs::StdRng};
 use tokio::net::TcpListener;
@@ -36,7 +42,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                         _ => {}
                     },
                     Err(err) => {
-                        println!("Error reading message: {err}");
+                        eprintln!("Error reading message: {err}");
 
                         send!(websocketz, Message::Close(None))?;
 

examples/simple.rs

@@ -1,19 +1,37 @@
+//! Run with
+//!
+//! ```not_rust
+//! cargo run --example simple
+//! ```
+
 use embedded_io_adapters::tokio_1::FromTokio;
 use rand::{SeedableRng, rngs::StdRng};
 use tokio::net::TcpStream;
-use websocketz::{Message, WebSocket, next, options::ConnectOptions};
+use websocketz::{Message, WebSocket, http::Header, next, options::ConnectOptions};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let stream = TcpStream::connect("127.0.0.1:9002").await?;
+    let domain = "websockets.chilkat.io";
+
+    let addr = tokio::net::lookup_host((domain, 80))
+        .await?
+        .next()
+        .ok_or("Failed to resolve domain")?;
+
+    let stream = TcpStream::connect(addr).await?;
 
     let read_buf = &mut [0u8; 8192 * 2];
     let write_buf = &mut [0u8; 8192 * 2];
     let fragments_buf = &mut [0u8; 8192 * 2];
     let rng = StdRng::from_os_rng();
 
     let mut websocketz = WebSocket::connect::<16>(
-        ConnectOptions::default(),
+        ConnectOptions::default()
+            .with_path_unchecked("/wsChilkatEcho.ashx")
+            .with_headers(&[Header {
+                name: "Host",
+                value: domain.as_bytes(),
+            }]),
         FromTokio::new(stream),
         rng,
         read_buf,
@@ -27,14 +45,26 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         websocketz.framable()
     );
 
-    websocketz.send(Message::Text("Hello, WebSocket!")).await?;
+    'ws: loop {
+        websocketz.send(Message::Text("Hello, WebSocket!")).await?;
+
+        match next!(websocketz) {
+            None => {
+                println!("EOF");
+
+                break 'ws;
+            }
+            Some(Ok(msg)) => {
+                println!("Received message: {msg:?}");
+            }
+            Some(Err(err)) => {
+                eprintln!("Error receiving message: {err:?}");
 
-    websocketz
-        .send_fragmented(Message::Text("Hello, Fragmented WebSocket!"), 4)
-        .await?;
+                break 'ws;
+            }
+        }
 
-    while let Some(message) = next!(websocketz).transpose()? {
-        println!("Received message: {message:?}");
+        tokio::time::sleep(tokio::time::Duration::from_millis(500)).await;
     }
 
     Ok(())

examples/split.rs

@@ -0,0 +1,60 @@
+//! Run with
+//!
+//! ```not_rust
+//! cargo run --example split
+//! ```
+
+use embedded_io_adapters::tokio_1::FromTokio;
+use rand::{SeedableRng, rngs::StdRng};
+use tokio::{
+    io::{ReadHalf, WriteHalf},
+    net::TcpStream,
+};
+use websocketz::{Message, WebSocket, next, options::ConnectOptions};
+
+fn split(
+    stream: FromTokio<TcpStream>,
+) -> (
+    FromTokio<ReadHalf<TcpStream>>,
+    FromTokio<WriteHalf<TcpStream>>,
+) {
+    let (read, write) = tokio::io::split(stream.into_inner());
+
+    (FromTokio::new(read), FromTokio::new(write))
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let stream = TcpStream::connect("127.0.0.1:9002").await?;
+
+    let read_buf = &mut [0u8; 8192 * 2];
+    let write_buf = &mut [0u8; 8192 * 2];
+    let fragments_buf = &mut [0u8; 8192 * 2];
+    let rng = StdRng::from_os_rng();
+
+    let websocketz = WebSocket::connect::<16>(
+        ConnectOptions::default(),
+        FromTokio::new(stream),
+        rng,
+        read_buf,
+        write_buf,
+        fragments_buf,
+    )
+    .await?;
+
+    let (mut websocketz_read, mut websocketz_write) = websocketz.split_with(split);
+
+    websocketz_write
+        .send(Message::Text("Hello, WebSocket!"))
+        .await?;
+
+    websocketz_write
+        .send_fragmented(Message::Text("Hello, Fragmented WebSocket!"), 4)
+        .await?;
+
+    while let Some(message) = next!(websocketz_read).transpose()? {
+        println!("Received message: {message:?}");
+    }
+
+    Ok(())
+}