(edge-http) Server non-static handler (#40)

* Handlers with non-static socket factories

* embedded-svc compat

Author: ivmarkov

edge-http/README.md

@@ -68,8 +68,8 @@ where
     Ok(())
 }
 
-async fn request<'b, const N: usize, T: TcpConnect>(
-    conn: &mut Connection<'b, T, N>,
+async fn request<const N: usize, T: TcpConnect>(
+    conn: &mut Connection<'_, T, N>,
     uri: &str,
 ) -> Result<(), Error<T::Error>> {
     conn.initiate_request(true, Method::Get, uri, &[("Host", "httpbin.org")])
@@ -103,7 +103,7 @@ async fn request<'b, const N: usize, T: TcpConnect>(
 ### HTTP server
 
 ```rust
-use core::fmt::Display;
+use core::fmt::{Debug, Display};
 
 use edge_http::io::server::{Connection, DefaultServer, Handler};
 use edge_http::io::Error;
@@ -140,17 +140,20 @@ pub async fn run(server: &mut DefaultServer) -> Result<(), anyhow::Error> {
 
 struct HttpHandler;
 
-impl<'b, T, const N: usize> Handler<'b, T, N> for HttpHandler
-where
-    T: Read + Write,
-{
-    type Error = Error<T::Error>;
+impl Handler for HttpHandler {
+    type Error<E>
+        = Error<E>
+    where
+        E: Debug;
 
-    async fn handle(
+    async fn handle<T, const N: usize>(
         &self,
         _task_id: impl Display + Copy,
-        conn: &mut Connection<'b, T, N>,
-    ) -> Result<(), Self::Error> {
+        conn: &mut Connection<'_, T, N>,
+    ) -> Result<(), Self::Error<T::Error>>
+    where
+        T: Read + Write,
+    {
         let headers = conn.headers()?;
 
         if headers.method != Method::Get {

edge-http/src/io.rs

@@ -373,7 +373,7 @@ where
     Ok((connection_type, body_type))
 }
 
-impl<'b, const N: usize> Headers<'b, N> {
+impl<const N: usize> Headers<'_, N> {
     fn resolve<E>(
         &self,
         carry_over_connection_type: Option<ConnectionType>,
@@ -497,7 +497,7 @@ where
     type Error = Error<R::Error>;
 }
 
-impl<'b, R> Read for Body<'b, R>
+impl<R> Read for Body<'_, R>
 where
     R: Read,
 {
@@ -545,7 +545,7 @@ where
     type Error = R::Error;
 }
 
-impl<'b, R> Read for PartiallyRead<'b, R>
+impl<R> Read for PartiallyRead<'_, R>
 where
     R: Read,
 {
@@ -824,7 +824,7 @@ where
     type Error = Error<R::Error>;
 }
 
-impl<'b, R> Read for ChunkedRead<'b, R>
+impl<R> Read for ChunkedRead<'_, R>
 where
     R: Read,
 {

edge-http/src/io/client.rs

@@ -401,7 +401,7 @@ where
     type Error = Error<T::Error>;
 }
 
-impl<'b, T, const N: usize> Read for Connection<'b, T, N>
+impl<T, const N: usize> Read for Connection<'_, T, N>
 where
     T: TcpConnect,
 {
@@ -410,7 +410,7 @@ where
     }
 }
 
-impl<'b, T, const N: usize> Write for Connection<'b, T, N>
+impl<T, const N: usize> Write for Connection<'_, T, N>
 where
     T: TcpConnect,
 {
@@ -473,7 +473,7 @@ mod embedded_svc_compat {
 
     use embedded_svc::http::client::asynch::{Connection, Headers, Method, Status};
 
-    impl<'b, T, const N: usize> Headers for super::Connection<'b, T, N>
+    impl<T, const N: usize> Headers for super::Connection<'_, T, N>
     where
         T: TcpConnect,
     {
@@ -484,7 +484,7 @@ mod embedded_svc_compat {
         }
     }
 
-    impl<'b, T, const N: usize> Status for super::Connection<'b, T, N>
+    impl<T, const N: usize> Status for super::Connection<'_, T, N>
     where
         T: TcpConnect,
     {