refactoring and adding non-tls example

Cargo.toml

@@ -78,13 +78,23 @@ default = [
 tcp = []
 dns = ["embassy-net/dns"]
 tls = []
-websocket = []
+websocket = ["embedded-websocket"]
 json-rpc = []
 std = [
-    "dep:tokio",
+    "tokio",
     "embedded-io-adapters/tokio-1",
     "embedded-websocket/std",
     "tokio-rustls",
     "webpki-roots",
 ]
 webpki-roots = ["dep:webpki-roots"]
+
+[[example]]
+name = "std_async_web_socket_client"
+path = "examples/std_async_web_socket_client.rs"
+required-features = ["std", "tcp", "websocket"]
+
+[[example]]
+name = "std_tls_async_web_socket_client"
+path = "examples/std_tls_async_web_socket_client.rs"
+required-features = ["std", "tcp", "tls", "websocket"]

examples/std_async_web_socket_client.rs

@@ -0,0 +1,47 @@
+use em_as_net::{
+    client::websocket::{
+        AsyncWebSocketClient, ReadResult, WebSocketRead, WebSocketSendMessageType, WebSocketWrite,
+    },
+    core::tcp::TcpStream,
+};
+use rand::thread_rng;
+use url::Url;
+
+#[tokio::main]
+async fn main() {
+    let uri = Url::parse("ws://ws.vi-server.org:80/mirror/").unwrap();
+    let mut stream = TcpStream::connect(&uri).await.unwrap();
+    println!("TCP Connected");
+    let mut buffer = [0u8; 4096];
+    let rng = thread_rng();
+    let mut websocket = AsyncWebSocketClient::open(&mut stream, &mut buffer, &uri, rng, None, None)
+        .await
+        .unwrap();
+    println!("WebSocket Connected");
+    websocket
+        .write(
+            &mut stream,
+            &mut buffer,
+            WebSocketSendMessageType::Text,
+            true,
+            "Hello World".as_bytes(),
+        )
+        .await
+        .unwrap();
+    println!("Message Sent");
+    loop {
+        let message = websocket
+            .try_read(&mut stream, &mut buffer)
+            .await
+            .unwrap()
+            .unwrap();
+        match message {
+            ReadResult::Text(text) => {
+                assert_eq!("Hello World".to_string(), text);
+                println!("Received message: {}", text);
+            }
+            _ => panic!("Expected 'Hello World' as text message."),
+        }
+        break;
+    }
+}