diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-17 19:55:15 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-17 19:55:15 +0300 |
| commit | ab690ab9c6ae2b00aef1b501e8b17ff02b5da753 (patch) | |
| tree | 0a58b043605ef1d9b09e75b207c236aacb1ed55a /tests/plugins/broadcast/broadcast_plugin_test.go | |
| parent | bd0da830ae345e1ed4a67782bf413673beeba037 (diff) | |
Update to go 1.17
Add Stat with tests
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.go | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/tests/plugins/broadcast/broadcast_plugin_test.go b/tests/plugins/broadcast/broadcast_plugin_test.go index c7041cc9..3dcc5c2c 100644 --- a/tests/plugins/broadcast/broadcast_plugin_test.go +++ b/tests/plugins/broadcast/broadcast_plugin_test.go @@ -279,8 +279,11 @@ func TestBroadcastSameSubscriber(t *testing.T) { time.Sleep(time.Second * 2) t.Run("PublishHelloFooFoo2Foo3", BroadcastPublishFooFoo2Foo3("6002")) + time.Sleep(time.Second) t.Run("PublishHelloFoo2", BroadcastPublishFoo2("6002")) + time.Sleep(time.Second) t.Run("PublishHelloFoo3", BroadcastPublishFoo3("6002")) + time.Sleep(time.Second) t.Run("PublishAsyncHelloFooFoo2Foo3", BroadcastPublishAsyncFooFoo2Foo3("6002")) time.Sleep(time.Second * 5) @@ -291,6 +294,8 @@ func TestBroadcastSameSubscriber(t *testing.T) { t.Run("RedisFlush", redisFlushAll("127.0.0.1:6379")) t.Run("RedisFlush", redisFlushAll("127.0.0.1:6378")) + + time.Sleep(time.Second * 5) } func TestBroadcastSameSubscriberGlobal(t *testing.T) { @@ -395,8 +400,11 @@ func TestBroadcastSameSubscriberGlobal(t *testing.T) { time.Sleep(time.Second * 2) t.Run("PublishHelloFooFoo2Foo3", BroadcastPublishFooFoo2Foo3("6003")) + time.Sleep(time.Second) t.Run("PublishHelloFoo2", BroadcastPublishFoo2("6003")) + time.Sleep(time.Second) t.Run("PublishHelloFoo3", BroadcastPublishFoo3("6003")) + time.Sleep(time.Second) t.Run("PublishAsyncHelloFooFoo2Foo3", BroadcastPublishAsyncFooFoo2Foo3("6003")) time.Sleep(time.Second * 4) @@ -404,6 +412,7 @@ func TestBroadcastSameSubscriberGlobal(t *testing.T) { stopCh <- struct{}{} wg.Wait() + time.Sleep(time.Second * 5) t.Run("RedisFlush", redisFlushAll("127.0.0.1:6379")) |