chore: cleanup and expose API

src/error.rs

@@ -20,28 +20,28 @@ struct ErrorImpl {
 /// Enum representing different kinds of errors that can occur.
 /// Currently, only includes a Transport variant, but can be extended for more error types.
 #[derive(Debug)]
-pub(crate) enum Kind {
+pub enum Kind {
     Transport,
 }
 
 impl Error {
     /// Creates a new Error with a specific kind.
-    pub(crate) fn new(kind: Kind) -> Self {
+    pub fn new(kind: Kind) -> Self {
         Self {
             inner: ErrorImpl { kind, source: None },
         }
     }
 
     /// Attaches a source error to this Error.
     /// This method consumes self and returns a new Error, allowing for method chaining.
-    pub(crate) fn with(mut self, source: impl Into<Source>) -> Self {
+    pub fn with(mut self, source: impl Into<Source>) -> Self {
         self.inner.source = Some(source.into());
         self
     }
 
     /// Creates a new Transport Error with the given source.
     /// This is a convenience method combining new() and with().
-    pub(crate) fn from_source(source: impl Into<crate::Error>) -> Self {
+    pub fn from_source(source: impl Into<crate::Error>) -> Self {
         Error::new(Kind::Transport).with(source)
     }
 

src/http.rs

@@ -7,7 +7,7 @@ use http_body::Body;
 use hyper::body::Incoming;
 use hyper::service::Service;
 use hyper_util::{
-    rt::{TokioExecutor, TokioIo},
+    rt::TokioIo,
     server::conn::auto::{Builder as HttpConnectionBuilder, HttpServerConnExec},
 };
 use tokio::io::{AsyncRead, AsyncWrite};
@@ -232,6 +232,7 @@ mod tests {
     use bytes::Bytes;
     use http_body_util::{BodyExt, Empty, Full};
     use hyper::{body::Incoming, Request, Response, StatusCode};
+    use hyper_util::rt::TokioExecutor;
     use hyper_util::service::TowerToHyperService;
     use tokio::net::{TcpListener, TcpStream};
     use tokio::sync::oneshot;

src/lib.rs

@@ -1,12 +1,15 @@
+pub use error::{Error as TransportError, Kind as TransportErrorKind};
+pub use http::serve_http_connection;
+pub use http::serve_http_with_shutdown;
+pub use tcp::serve_tcp_incoming;
+pub use tls::load_certs;
+pub use tls::load_private_key;
+pub use tls::serve_tls_incoming;
+
 mod error;
 mod fuse;
 mod http;
 mod tcp;
 mod tls;
 
-pub use tcp::serve_tcp_incoming;
-pub use tls::serve_tls_incoming;
-pub use http::serve_http_with_shutdown;
-pub use http::serve_http_connection;
-
 pub(crate) type Error = Box<dyn std::error::Error + Send + Sync>;

src/tls.rs

@@ -108,10 +108,9 @@ mod tests {
     use super::*;
     use crate::tcp::serve_tcp_incoming;
     use futures::StreamExt;
-    use rustls::pki_types::{CertificateDer, PrivateKeyDer, ServerName};
+    use rustls::pki_types::{CertificateDer, ServerName};
     use rustls::{ClientConfig, ServerConfig};
     use std::net::SocketAddr;
-    use std::pin::Pin;
     use std::sync::Arc;
     use tokio::io::{AsyncRead, AsyncWrite};
     use tokio::net::{TcpListener, TcpStream};