Improve protocol format

1 files changed, 8 insertions, 6 deletions

diff --git a/cmd/client/main.go b/cmd/client/main.go
index a229632..8bb1c24 100644
--- a/cmd/client/main.go
+++ b/cmd/client/main.go
@@ -23,17 +23,19 @@ func main() {
 	}
 	defer conn.Close()
 
-	go ping(conn)
-	if err := core.Loop(conn); err != nil {
-		log.Fatal("event loop error ", err)
-	}
+	ping(conn)
 }
 
 func ping(conn net.Conn) {
 	for {
 		log.Print("ping")
-		p := core.Ping{}
-		core.Send(conn, core.TypePing, p)
+		data, err := core.Encode(core.Ping{})
+		if err != nil {
+			panic(err)
+		}
+		if _, err := conn.Write(data); err != nil {
+			panic(err)
+		}
 		time.Sleep(time.Second)
 	}
 }