test

tcp-connection.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	"bufio"
 	"encoding/binary"
 	"fmt"
 	"log"
@@ -111,15 +110,15 @@ func (c *Connection) Call(msg FrameType, data []byte) (*FrameWithPayload, error)
 func WaitForFrame(conn net.Conn, resultChan chan<- FrameWithPayload) error {
 	var err error
 	var frame Frame
-	r := bufio.NewReader(conn)
+	//r := bufio.NewReader(conn)
 
-	err = binary.Read(r, binary.LittleEndian, &frame)
+	err = binary.Read(conn, binary.LittleEndian, &frame)
 	if err != nil {
 		return err
 	}
 	if frame.IsValid() {
 		payload := make([]byte, frame.Length)
-		_, err = r.Read(payload)
+		_, err = conn.Read(payload)
 		if err != nil {
 			return err
 		}