diff --git a/database/socket/client/dial.go b/database/socket/client/dial.go index 33edd02b..56b9ecc3 100644 --- a/database/socket/client/dial.go +++ b/database/socket/client/dial.go @@ -33,7 +33,7 @@ func Dial(ctype, addr string) *Dialer { } func (d *Dialer) Start() { - go d.reciever() + go d.receiver() d.parser() } func (d *Dialer) Close() { @@ -41,7 +41,7 @@ func (d *Dialer) Close() { close(d.quit) } -func (d *Dialer) reciever() { +func (d *Dialer) receiver() { decoder := json.NewDecoder(d.conn) var msg socket.Message @@ -83,4 +83,4 @@ func (d *Dialer) parser() { } } } -} +} \ No newline at end of file diff --git a/database/socket/client/dial_test.go b/database/socket/client/dial_test.go index 9cb8178f..6addd29b 100644 --- a/database/socket/client/dial_test.go +++ b/database/socket/client/dial_test.go @@ -16,7 +16,7 @@ func TestConnectError(t *testing.T) { }, "could connect") } -func TestRecieveMessages(t *testing.T) { +func TestReceiveMessages(t *testing.T) { assert := assert.New(t) server, err := socket.Connect(map[string]interface{}{ "enable": true, @@ -66,4 +66,4 @@ func TestRecieveMessages(t *testing.T) { assert.False(runned, "message recieve") server.Close() -} +} \ No newline at end of file diff --git a/database/socket/internal.go b/database/socket/internal.go index 17998ee4..22a10168 100644 --- a/database/socket/internal.go +++ b/database/socket/internal.go @@ -26,10 +26,10 @@ func (conn *Connection) sendJSON(msg Message) { err := d.Encode(&msg) if err != nil { - log.Println("[socket-database] client has not recieve event:", err) + log.Println("[socket-database] client has not receive event:", err) c.Close() delete(conn.clients, addr) } } conn.clientMux.Unlock() -} +} \ No newline at end of file