summaryrefslogtreecommitdiff
path: root/plugins/broadcast/root/client_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/broadcast/root/client_test.go')
-rw-r--r--plugins/broadcast/root/client_test.go59
1 files changed, 0 insertions, 59 deletions
diff --git a/plugins/broadcast/root/client_test.go b/plugins/broadcast/root/client_test.go
deleted file mode 100644
index 52a50d57..00000000
--- a/plugins/broadcast/root/client_test.go
+++ /dev/null
@@ -1,59 +0,0 @@
-package broadcast
-
-import (
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-func Test_Client_Topics(t *testing.T) {
- br, _, c := setup(`{}`)
- defer c.Stop()
-
- client := br.NewClient()
- defer client.Close()
-
- assert.Equal(t, []string{}, client.Topics())
-
- assert.NoError(t, client.Subscribe("topic"))
- assert.Equal(t, []string{"topic"}, client.Topics())
-
- assert.NoError(t, client.Subscribe("topic"))
- assert.Equal(t, []string{"topic"}, client.Topics())
-
- assert.NoError(t, br.broker.Subscribe(client.upstream, "topic"))
- assert.Equal(t, []string{"topic"}, client.Topics())
-
- assert.NoError(t, br.Broker().Publish(newMessage("topic", "hello1")))
- assert.Equal(t, `hello1`, readStr(<-client.Channel()))
-
- assert.NoError(t, client.Unsubscribe("topic"))
- assert.NoError(t, client.Unsubscribe("topic"))
- assert.NoError(t, br.broker.Unsubscribe(client.upstream, "topic"))
-
- assert.Equal(t, []string{}, client.Topics())
-}
-
-func Test_Client_Patterns(t *testing.T) {
- br, _, c := setup(`{}`)
- defer c.Stop()
-
- client := br.NewClient()
- defer client.Close()
-
- assert.Equal(t, []string{}, client.Patterns())
-
- assert.NoError(t, client.SubscribePattern("topic/*"))
- assert.Equal(t, []string{"topic/*"}, client.Patterns())
-
- assert.NoError(t, br.broker.SubscribePattern(client.upstream, "topic/*"))
- assert.Equal(t, []string{"topic/*"}, client.Patterns())
-
- assert.NoError(t, br.Broker().Publish(newMessage("topic/1", "hello1")))
- assert.Equal(t, `hello1`, readStr(<-client.Channel()))
-
- assert.NoError(t, client.UnsubscribePattern("topic/*"))
- assert.NoError(t, br.broker.UnsubscribePattern(client.upstream, "topic/*"))
-
- assert.Equal(t, []string{}, client.Patterns())
-}