1 files changed, 0 insertions, 72 deletions
diff --git a/plugins/broadcast/root/rpc_test.go b/plugins/broadcast/root/rpc_test.go
deleted file mode 100644
index 157c4e70..00000000
--- a/plugins/broadcast/root/rpc_test.go
+++ /dev/null
@@ -1,72 +0,0 @@
-package broadcast
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-)
-
-func TestRPC_Broadcast(t *testing.T) {
-	br, rpc, c := setup(`{}`)
-	defer c.Stop()
-
-	client := br.NewClient()
-	defer client.Close()
-
-	rcpClient, err := rpc.Client()
-	assert.NoError(t, err)
-
-	// must not be delivered
-	ok := false
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.Publish",
-		[]*Message{newMessage("topic", `"hello1"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-
-	assert.NoError(t, client.Subscribe("topic"))
-
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.Publish",
-		[]*Message{newMessage("topic", `"hello1"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-	assert.Equal(t, `"hello1"`, readStr(<-client.Channel()))
-
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.Publish",
-		[]*Message{newMessage("topic", `"hello2"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-	assert.Equal(t, `"hello2"`, readStr(<-client.Channel()))
-
-	assert.NoError(t, client.Unsubscribe("topic"))
-
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.Publish",
-		[]*Message{newMessage("topic", `"hello3"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-
-	assert.NoError(t, client.Subscribe("topic"))
-
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.Publish",
-		[]*Message{newMessage("topic", `"hello4"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-	assert.Equal(t, `"hello4"`, readStr(<-client.Channel()))
-
-	assert.NoError(t, rcpClient.Call(
-		"broadcast.PublishAsync",
-		[]*Message{newMessage("topic", `"hello5"`)},
-		&ok,
-	))
-	assert.True(t, ok)
-	assert.Equal(t, `"hello5"`, readStr(<-client.Channel()))
-}