diff options
Diffstat (limited to 'tests/plugins/websockets')
| -rw-r--r-- | tests/plugins/websockets/websocket_plugin_test.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/tests/plugins/websockets/websocket_plugin_test.go b/tests/plugins/websockets/websocket_plugin_test.go index 40f37e89..53b6a572 100644 --- a/tests/plugins/websockets/websocket_plugin_test.go +++ b/tests/plugins/websockets/websocket_plugin_test.go @@ -667,9 +667,9 @@ func RPCWsPubAsync(port string) func(t *testing.T) { messagesToVerify = append(messagesToVerify, `{"topic":"foo2","payload":"hello, PHP2"}`) i := 0 for { - _, msg, err := c.ReadMessage() + _, msg, err2 := c.ReadMessage() retMsg := utils.AsString(msg) - assert.NoError(t, err) + assert.NoError(t, err2) assert.Equal(t, messagesToVerify[i], retMsg) i++ if i == 3 { @@ -744,9 +744,9 @@ func RPCWsPub(port string) func(t *testing.T) { messagesToVerify = append(messagesToVerify, `{"topic":"foo2","payload":"hello, PHP2"}`) i := 0 for { - _, msg, err := c.ReadMessage() + _, msg, err2 := c.ReadMessage() retMsg := utils.AsString(msg) - assert.NoError(t, err) + assert.NoError(t, err2) assert.Equal(t, messagesToVerify[i], retMsg) i++ if i == 3 { |