diff options
Diffstat (limited to 'tests/plugins/broadcast/broadcast_plugin_test.go')
| -rw-r--r-- | tests/plugins/broadcast/broadcast_plugin_test.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/tests/plugins/broadcast/broadcast_plugin_test.go b/tests/plugins/broadcast/broadcast_plugin_test.go index 65ee4415..5b195bd0 100644 --- a/tests/plugins/broadcast/broadcast_plugin_test.go +++ b/tests/plugins/broadcast/broadcast_plugin_test.go @@ -98,8 +98,7 @@ func TestBroadcastInit(t *testing.T) { } }() - time.Sleep(time.Second * 1) - //t.Run("TestWSInit", wsInit) + t.Run("TestWSInit", wsInit) stopCh <- struct{}{} @@ -186,7 +185,7 @@ func messageWS(command string, broker string, payload []byte, topics ...string) return &websocketsv1.Message{ Topics: topics, Command: command, - Broker: broker, + //Broker: broker, Payload: payload, } } @@ -197,7 +196,7 @@ func makeMessage(command string, broker string, payload []byte, topics ...string { Topics: topics, Command: command, - Broker: broker, + //Broker: broker, Payload: payload, }, }, |