summaryrefslogtreecommitdiff
path: root/tests/plugins/broadcast/broadcast_plugin_test.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-06-18 01:06:16 +0300
committerValery Piashchynski <[email protected]>2021-06-18 01:06:16 +0300
commitfe7bb0fe758d573fe353df028257ed66c6eccf66 (patch)
tree74392f8e61e96c85f0d8b684cfc08e3fc3664ae9 /tests/plugins/broadcast/broadcast_plugin_test.go
parent68ff941c4226074206ceed9c30bd95317aa0e9fc (diff)
- Rework main parts
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins/broadcast/broadcast_plugin_test.go')
-rw-r--r--tests/plugins/broadcast/broadcast_plugin_test.go7
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,
},
},