maybe non blocking with a new reader

tcp-mux-server.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"bufio"
 	"encoding/binary"
 	"io"
 	"log"
@@ -100,8 +101,9 @@ func (m *TCPServerMux) HandleConnection(connection net.Conn) error {
 
 	defer connection.Close()
 	var packet Packet
+	reader := bufio.NewReader(connection)
 	for {
-		err := ReadPacket(connection, &packet)
+		err := ReadPacket(reader, &packet)
 		if err != nil {
 			if err == io.EOF {
 				return nil
@@ -113,7 +115,7 @@ func (m *TCPServerMux) HandleConnection(connection net.Conn) error {
 			log.Printf("Incorrect package version: %v\n", err)
 			continue
 		}
-		data, err := GetPacketData(connection, packet.DataLength)
+		data, err := GetPacketData(reader, packet.DataLength)
 		if err != nil {
 			log.Printf("Error receiving packet data: %v\n", err)
 		}