Method ReadBytes

client/internal/network/conn.go:65–78

(l int)

}

func (t *TCPClient) ReadBytes(l int) ([]byte, error) {
	buf := make([]byte, l)
	if conn := t.getConn(); conn != nil {
		_, err := io.ReadFull(conn, buf)
		if err != nil {
			// time.Sleep(time.Millisecond * 100) // 服务器会发送offline包后立即断开连接, 此时还没解析, 可能还是得加锁
			t.unexpectedClose(err)
			return nil, ErrConnectionClosed
		}
		return buf, nil
	}

	return nil, ErrConnectionClosed
}

func (t *TCPClient) ReadInt32() (int32, error) {
	b, err := t.ReadBytes(4)