refactor!: Reimplement stream without split

Cargo.toml

@@ -12,7 +12,7 @@ exclude = [".github"]
 [features]
 default = ["stream"]
 expose_stream = []
-stream = ["dep:bytes", "dep:tokio", "dep:tokio-rustls"]
+stream = ["dep:bytes", "dep:tokio"]
 
 # <Forward to imap-codec>
 arbitrary = ["imap-codec/arbitrary"]
@@ -33,8 +33,7 @@ ext_metadata = ["imap-codec/ext_metadata"]
 bytes = { version = "1.7.1", optional = true }
 imap-codec = { version = "2.0.0-alpha.5", features = ["quirk_crlf_relaxed"] }
 thiserror = "1.0.63"
-tokio = { version = "1.40.0", optional = true, features = ["io-util", "macros", "net"] }
-tokio-rustls = { version = "0.26.0", optional = true, default-features = false }
+tokio = { version = "1.40.0", optional = true, features = ["io-util", "net"] }
 tracing = "0.1.40"
 
 [dev-dependencies]

README.md

@@ -58,7 +58,7 @@ use tokio::net::TcpStream;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
-    let mut stream = Stream::insecure(TcpStream::connect("127.0.0.1:1143").await?);
+    let mut stream = Stream::new(TcpStream::connect("127.0.0.1:1143").await?);
     let mut client = Client::new(Options::default());
 
     loop {

examples/client.rs

@@ -11,7 +11,7 @@ use tokio::net::TcpStream;
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
     let stream = TcpStream::connect("127.0.0.1:12345").await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut client = Client::new(Options::default());
 
     let greeting = loop {

examples/client_authenticate.rs

@@ -14,7 +14,7 @@ use tokio::net::TcpStream;
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
     let stream = TcpStream::connect("127.0.0.1:12345").await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut client = Client::new(Options::default());
 
     loop {

examples/client_idle.rs

@@ -14,7 +14,7 @@ use tokio::{net::TcpStream, sync::mpsc::Receiver};
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
     let stream = TcpStream::connect("127.0.0.1:12345").await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut client = Client::new(Options::default());
 
     loop {

examples/server.rs

@@ -11,7 +11,7 @@ use tokio::net::TcpListener;
 async fn main() {
     let listener = TcpListener::bind("127.0.0.1:12345").await.unwrap();
     let (stream, _) = listener.accept().await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut server = Server::new(
         Options::default(),
         Greeting::ok(None, "server (example)").unwrap(),

examples/server_authenticate.rs

@@ -10,7 +10,7 @@ use tokio::net::TcpListener;
 async fn main() {
     let listener = TcpListener::bind("127.0.0.1:12345").await.unwrap();
     let (stream, _) = listener.accept().await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut server = Server::new(
         Options::default(),
         Greeting::ok(None, "server_idle (example)").unwrap(),

examples/server_idle.rs

@@ -16,7 +16,7 @@ use tokio::{net::TcpListener, sync::mpsc::Receiver};
 async fn main() {
     let listener = TcpListener::bind("127.0.0.1:12345").await.unwrap();
     let (stream, _) = listener.accept().await.unwrap();
-    let mut stream = Stream::insecure(stream);
+    let mut stream = Stream::new(stream);
     let mut server = Server::new(
         Options::default(),
         Greeting::ok(None, "server_idle (example)").unwrap(),

integration-test/Cargo.toml

@@ -8,7 +8,7 @@ publish = false
 [dependencies]
 bstr = { version = "1.10.0", default-features = false }
 bytes = "1.7.1"
-imap-codec = { version = "2.0.0-alpha.4" }
+imap-codec = { version = "2.0.0-alpha.5" }
 imap-next = { path = ".." }
 tokio = { version = "1.40.0", features = ["macros", "net", "rt", "time"] }
 tracing = "0.1.40"

integration-test/src/client_tester.rs

@@ -25,7 +25,7 @@ impl ClientTester {
     ) -> Self {
         let stream = TcpStream::connect(server_address).await.unwrap();
         trace!(?server_address, "Client is connected");
-        let stream = Stream::insecure(stream);
+        let stream = Stream::new(stream);
         let client = Client::new(client_options);
         Self {
             codecs,
@@ -344,13 +344,16 @@ impl ClientTester {
 #[allow(clippy::large_enum_variant)]
 enum ConnectionState {
     /// Connection to server established.
-    Connected { stream: Stream, client: Client },
+    Connected {
+        stream: Stream<TcpStream>,
+        client: Client,
+    },
     /// Connection dropped.
     Disconnected,
 }
 
 impl ConnectionState {
-    fn connected(&mut self) -> (&mut Stream, &mut Client) {
+    fn connected(&mut self) -> (&mut Stream<TcpStream>, &mut Client) {
         match self {
             ConnectionState::Connected { stream, client } => (stream, client),
             ConnectionState::Disconnected => panic!("Client is already disconnected"),

integration-test/src/server_tester.rs

@@ -4,7 +4,7 @@ use imap_next::{
     server::{self, ResponseHandle, Server},
     stream::{self, Stream},
 };
-use tokio::net::TcpListener;
+use tokio::net::{TcpListener, TcpStream};
 use tracing::trace;
 
 use crate::codecs::Codecs;
@@ -24,7 +24,7 @@ impl ServerTester {
     ) -> Self {
         let (stream, client_address) = server_listener.accept().await.unwrap();
         trace!(?client_address, "Server accepts connection");
-        let stream = Stream::insecure(stream);
+        let stream = Stream::new(stream);
         Self {
             codecs,
             server_options,
@@ -308,15 +308,20 @@ impl ServerTester {
 #[allow(clippy::large_enum_variant)]
 enum ConnectionState {
     // Connection to client established.
-    Connected { stream: Stream },
+    Connected {
+        stream: Stream<TcpStream>,
+    },
     // Server greeted client.
-    Greeted { stream: Stream, server: Server },
+    Greeted {
+        stream: Stream<TcpStream>,
+        server: Server,
+    },
     // Connection dropped.
     Disconnected,
 }
 
 impl ConnectionState {
-    fn greeted(&mut self) -> (&mut Stream, &mut Server) {
+    fn greeted(&mut self) -> (&mut Stream<TcpStream>, &mut Server) {
         match self {
             ConnectionState::Connected { .. } => panic!("Server has not greeted yet"),
             ConnectionState::Greeted { stream, server } => (stream, server),