Skip to content

Commit 6dde36f

Browse files
author
Evgeniy Ivakha
committed
parser fix
1 parent 226cddc commit 6dde36f

2 files changed

Lines changed: 7 additions & 4 deletions

File tree

parser.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,16 @@ func parseMessage(_msg []byte) (int, []interface{}, error) {
2828
return 0, nil, errors.New("unknown call type")
2929
}
3030

31-
func parseWampMessage(typ int, msg []interface{}) (*wampUnmarshaledMsg, error) {
31+
func parseWampMessage(typ int, msg []interface{}) (*wampMsg, error) {
3232
if typ == msgCall && len(msg) < 3 {
3333
return nil, errors.New("invalid wamp message")
34-
} else if len(msg) < 2 {
34+
}
35+
36+
if len(msg) < 2 {
3537
return nil, errors.New("invalid wamp message")
3638
}
37-
message := new(wampUnmarshaledMsg)
39+
40+
message := new(wampMsg)
3841
switch typ {
3942
case msgCall:
4043
if msg[1] == nil {

wango_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ func TestAcceptingConcurrentConnections(t *testing.T) {
2828

2929
totalConnections := len(server.connections)
3030
if totalConnections != numberConnections {
31-
t.Fatal("Invalid connections number when connecting", totalConnections)
31+
t.Fatalf("Invalid connections number %d when connecting, expected: %d", totalConnections, numberConnections)
3232
}
3333
}
3434

0 commit comments

Comments
 (0)