diff --git a/connection.go b/connection.go index 091a6c47..397cc6f7 100644 --- a/connection.go +++ b/connection.go @@ -144,7 +144,3 @@ func (c *conn) namespace(nsp string) *namespaceHandler { handler, _ := c.handlers.Get(nsp) return handler } - -func (c *conn) parseArgs(types []reflect.Type) ([]reflect.Value, error) { - return c.decoder.DecodeArgs(types) -} diff --git a/connection_handlers.go b/connection_handlers.go index c72a3baa..7e95f9c7 100644 --- a/connection_handlers.go +++ b/connection_handlers.go @@ -28,7 +28,7 @@ func ackPacketHandler(c *conn, header parser.Header) error { if !ok { // This should never get here and would be solved with generic sync.Map logger.Info("Incorrect Ack functinxo type") - rawFunc = emtpyFH // keep going + handler = emtpyFH // keep going } // Read the body because Ack can have body as well diff --git a/types.go b/types.go index bef1fbe4..f109e796 100644 --- a/types.go +++ b/types.go @@ -1,7 +1,6 @@ package socketio import ( - "github.com/googollee/go-socket.io/parser" "reflect" ) @@ -16,8 +15,6 @@ const ( clientDisconnectMsg = "client namespace disconnect" ) -type readHandler func(c *conn, header parser.Header) error - var ( defaultHeaderType = []reflect.Type{reflect.TypeOf("")} )