diff --git a/src/runtime/endpoint.rs b/src/runtime/endpoint.rs
index 5bf6f48d9ee1cdcf027d9332e1c9cc8df4cba735..359692552320f0bfbcbd269c5a5827581545e405 100644
--- a/src/runtime/endpoint.rs
+++ b/src/runtime/endpoint.rs
@@ -88,8 +88,11 @@ impl From<EndpointErr> for ConnectErr {
 }
 impl Endpoint {
     // asymmetric
-    pub(crate) fn from_fresh_stream(stream: mio::net::TcpStream) -> Self {
-        Self::Network(NetworkEndpoint { stream, inbox: vec![], outbox: vec![] })
+    // pub(crate) fn from_fresh_stream(stream: mio::net::TcpStream) -> Self {
+    //     Self::Network(NetworkEndpoint { stream, inbox: vec![], outbox: vec![] })
+    // }
+    pub(crate) fn from_fresh_stream_and_inbox(stream: mio::net::TcpStream, inbox: Vec<u8>) -> Self {
+        Self::Network(NetworkEndpoint { stream, inbox, outbox: vec![] })
     }
 
     // symmetric