remove anyhow requirement

Author: stevefan1999-personal

Cargo.toml

@@ -11,8 +11,8 @@ categories = ["embedded", "no-std", "network-programming"]
 readme = "README.md"
 
 [dependencies]
-anyhow = "1.0.58"
 async-std = { version = "1.12.0", optional = true }
+async-trait = { version = "0.1.56", optional = true }
 base64 = { version = "0.13.0", default-features = false }
 base64-simd = { version = "0.5.0", default-features = false, optional = true }
 byteorder = { version = "1.4.3", default-features = false }
@@ -43,7 +43,7 @@ tokio-stream = { version = "0.1.9", features = ["net"] }
 default = ["std"]
 # default = []
 std = []
-async = ["std"]
+async = ["std", "async-trait"]
 tokio = ["dep:tokio", "async"]
 futures = ["dep:futures", "async"]
 smol = ["dep:smol", "async"]

examples/client/main.rs

@@ -13,15 +13,13 @@ use embedded_websocket::{
     framer::{Framer, FramerError, ReadResult},
     WebSocketClient, WebSocketCloseStatusCode, WebSocketOptions, WebSocketSendMessageType,
 };
-use std::net::TcpStream;
+use std::{error::Error, net::TcpStream};
 
-fn main() -> Result<(), FramerError> {
+fn main() -> Result<(), FramerError<impl Error>> {
     // open a TCP stream to localhost port 1337
     let address = "127.0.0.1:1337";
     println!("Connecting to: {}", address);
-    let mut stream = TcpStream::connect(address)
-        .map_err(anyhow::Error::new)
-        .map_err(FramerError::Io)?;
+    let mut stream = TcpStream::connect(address).map_err(FramerError::Io)?;
     println!("Connected.");
 
     let mut read_buf = [0; 4000];

examples/client_async/main.rs

@@ -13,6 +13,7 @@ use embedded_websocket::{
     framer::{Framer, FramerError, ReadResult},
     WebSocketClient, WebSocketCloseStatusCode, WebSocketOptions, WebSocketSendMessageType,
 };
+use std::error::Error;
 
 cfg_if::cfg_if! {
     if #[cfg(feature = "tokio")] {
@@ -27,14 +28,11 @@ cfg_if::cfg_if! {
 #[cfg_attr(feature = "async-std", async_std::main)]
 #[cfg_attr(feature = "tokio", tokio::main)]
 #[cfg_attr(feature = "smol", smol_potat::main)]
-async fn main() -> Result<(), FramerError> {
+async fn main() -> Result<(), FramerError<impl Error>> {
     // open a TCP stream to localhost port 1337
     let address = "127.0.0.1:1337";
     println!("Connecting to: {}", address);
-    let mut stream = TcpStream::connect(address)
-        .await
-        .map_err(anyhow::Error::new)
-        .map_err(FramerError::Io)?;
+    let mut stream = TcpStream::connect(address).await.map_err(FramerError::Io)?;
     println!("Connected.");
 
     let mut read_buf = [0; 4000];

examples/server/main.rs

@@ -27,7 +27,7 @@ type Result<T> = std::result::Result<T, WebServerError>;
 #[derive(Debug)]
 pub enum WebServerError {
     Io(std::io::Error),
-    Framer(FramerError),
+    Framer(FramerError<std::io::Error>),
     WebSocket(ws::Error),
     HttpError(String),
     Utf8Error,
@@ -39,8 +39,8 @@ impl From<std::io::Error> for WebServerError {
     }
 }
 
-impl From<FramerError> for WebServerError {
-    fn from(err: FramerError) -> WebServerError {
+impl From<FramerError<std::io::Error>> for WebServerError {
+    fn from(err: FramerError<std::io::Error>) -> WebServerError {
         WebServerError::Framer(err)
     }
 }

examples/server_async/main.rs

@@ -47,7 +47,7 @@ cfg_if::cfg_if! {
 #[derive(Debug)]
 pub enum WebServerError {
     Io(std::io::Error),
-    Framer(FramerError),
+    Framer(FramerError<std::io::Error>),
     WebSocket(ws::Error),
     HttpError(String),
     Utf8Error,
@@ -59,8 +59,8 @@ impl From<std::io::Error> for WebServerError {
     }
 }
 
-impl From<FramerError> for WebServerError {
-    fn from(err: FramerError) -> WebServerError {
+impl From<FramerError<std::io::Error>> for WebServerError {
+    fn from(err: FramerError<std::io::Error>) -> WebServerError {
         WebServerError::Framer(err)
     }
 }