rename stream to socket stream

2 files changed, 6 insertions, 6 deletions

diff --git a/xmake/modules/private/service/server/remote_build_server.lua b/xmake/modules/private/service/server/remote_build_server.lua
index 57f697f59..a323132a6 100644
--- a/xmake/modules/private/service/server/remote_build_server.lua
+++ b/xmake/modules/private/service/server/remote_build_server.lua
@@ -20,7 +20,7 @@
 
 -- imports
 import("private.service.config")
-import("private.service.stream")
+import("private.service.socket_stream")
 import("private.service.message")
 import("private.service.server.server")
 
@@ -41,8 +41,8 @@ end
 
 -- handle ping message
 function remote_build_server:handle_ping(sock, msg)
-    local wstream = stream(sock)
-    if wstream:send_msg(message.new_ping()) and wstream:flush() then
+    local stream = socket_stream(sock)
+    if stream:send_msg(message.new_ping()) and stream:flush() then
         print("send ok")
     end
 end
diff --git a/xmake/modules/private/service/server/server.lua b/xmake/modules/private/service/server/server.lua
index d3035eddf..ea1831934 100644
--- a/xmake/modules/private/service/server/server.lua
+++ b/xmake/modules/private/service/server/server.lua
@@ -23,7 +23,7 @@ import("core.base.object")
 import("core.base.bytes")
 import("core.base.socket")
 import("core.base.scheduler")
-import("private.service.stream")
+import("private.service.socket_stream")
 import("private.service.message")
 
 -- define module
@@ -121,9 +121,9 @@ end
 -- handle session
 function server:_handle_session(sock)
     print("%s: %s session connected", self, sock)
-    local rstream = stream(sock)
+    local stream = socket_stream(sock)
     while true do
-        local msg = rstream:recv_object()
+        local msg = stream:recv_object()
         if msg then
             self:_HANDLER(sock, message(msg))
         else