order is important
This commit is contained in:
@@ -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) {
|
func (c *Connection) CallAsync(msg FrameType, payload []byte, ch chan<- FrameWithPayload) (net.Conn, error) {
|
||||||
conn, err := net.Dial("tcp", c.address)
|
conn, err := net.Dial("tcp", c.address)
|
||||||
go WaitForFrame(conn, ch)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return conn, err
|
return conn, err
|
||||||
}
|
}
|
||||||
|
go WaitForFrame(conn, ch)
|
||||||
|
|
||||||
toSend := MakeFrameWithPayload(msg, 1, payload)
|
toSend := MakeFrameWithPayload(msg, 1, payload)
|
||||||
|
|
||||||
err = SendFrame(conn, &toSend)
|
err = SendFrame(conn, &toSend)
|
||||||
|
|||||||
Reference in New Issue
Block a user