diff --git a/tcp-connection.go b/tcp-connection.go index 3f7230f..8875a18 100644 --- a/tcp-connection.go +++ b/tcp-connection.go @@ -74,10 +74,11 @@ func SendFrame(conn net.Conn, data *FrameWithPayload) error { func (c *Connection) CallAsync(msg FrameType, payload []byte, ch chan<- FrameWithPayload) (net.Conn, error) { conn, err := net.Dial("tcp", c.address) - go WaitForFrame(conn, ch) if err != nil { return conn, err } + go WaitForFrame(conn, ch) + toSend := MakeFrameWithPayload(msg, 1, payload) err = SendFrame(conn, &toSend)