diff options
Diffstat (limited to 'internal/server/tcpserver.go')
| -rw-r--r-- | internal/server/tcpserver.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/server/tcpserver.go b/internal/server/tcpserver.go index 21324c3..d952972 100644 --- a/internal/server/tcpserver.go +++ b/internal/server/tcpserver.go @@ -7,7 +7,7 @@ import ( "net" "codeberg.org/snonux/gorum/internal/config" - "codeberg.org/snonux/gorum/internal/tcp" + "codeberg.org/snonux/gorum/internal/iorw" ) type handlerCb func(message string) string @@ -49,7 +49,7 @@ func handleConnection(ctx context.Context, conn net.Conn, cb handlerCb) { log.Println("server: context done, disconnecting client:", remoteAddr) return default: - message, err := tcp.ReadStr(conn) + message, err := iorw.ReadStr(conn) if err != nil { log.Println("server: unable to read message", remoteAddr, err) return @@ -58,7 +58,7 @@ func handleConnection(ctx context.Context, conn net.Conn, cb handlerCb) { log.Println("server: received message", message, "from", remoteAddr) response := cb(message) - if err := tcp.WriteStr(conn, response); err != nil { + if err := iorw.WriteStr(conn, response); err != nil { log.Println("error:", err) } } |