removed outbound struct from public api

examples/outbound.rs

@@ -29,10 +29,10 @@ async fn main() -> Result<(), EslError> {
     let addr = "0.0.0.0:8085"; // Listening address
     println!("Listening on {}", addr);
     let listener = TcpListener::bind(addr).await?;
-    let listener = Esl::outbound(listener).await?;
 
     loop {
         let (socket, _) = listener.accept().await?;
+        let socket = Esl::outbound(socket).await?;
         tokio::spawn(async move { process_call(socket).await });
     }
 }

src/esl.rs

@@ -1,6 +1,6 @@
-use tokio::net::{TcpListener, ToSocketAddrs};
+use tokio::net::{TcpStream, ToSocketAddrs};
 
-use crate::{connection::EslConnection, outbound::Outbound, EslError};
+use crate::{connection::EslConnection, EslError};
 #[derive(Debug, Clone, PartialEq, Eq)]
 pub(crate) enum EslConnectionType {
     Inbound,
@@ -18,7 +18,9 @@ impl Esl {
     }
 
     /// Creates new server for outbound connection
-    pub async fn outbound(listener: TcpListener) -> Result<Outbound, EslError> {
-        Outbound::new(listener).await
+    pub async fn outbound(stream: TcpStream) -> Result<EslConnection, EslError> {
+        let connection =
+            EslConnection::with_tcpstream(stream, "None", EslConnectionType::Outbound).await?;
+        Ok(connection)
     }
 }

src/lib.rs

@@ -57,10 +57,10 @@
 //!     let addr = "0.0.0.0:8085"; // Listening address
 //!     println!("Listening on {}", addr);
 //!     let listener = TcpListener::bind(addr).await?;
-//!     let server = Esl::outbound(listener).await?;
 //!
 //!     loop {
-//!         let (socket, _) = server.accept().await?;
+//!         let (socket, _) = listener.accept().await?;
+//!         let socket = Esl::outbound(socket).await?;
 //!         tokio::spawn(async move { process_call(socket).await });
 //!     }
 //! }
@@ -73,7 +73,6 @@ pub(crate) mod error;
 pub(crate) mod esl;
 pub(crate) mod event;
 pub(crate) mod io;
-pub(crate) mod outbound;
 
 pub use connection::EslConnection;
 pub use error::*;