Use broadcast beta version

Author: rustatian

conn_context.go

@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 
 	"github.com/gorilla/websocket"
-	"github.com/spiral/broadcast"
+	"github.com/spiral/broadcast/v2"
 )
 
 // ConnContext carries information about websocket connection and it's topics.

conn_pool.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	"github.com/gorilla/websocket"
-	"github.com/spiral/broadcast"
+	"github.com/spiral/broadcast/v2"
 )
 
 // manages a set of websocket connections

go.mod

@@ -3,11 +3,11 @@ module github.com/spiral/broadcast-ws
 go 1.12
 
 require (
-	github.com/gorilla/websocket v1.4.1
-	github.com/prometheus/client_golang v1.2.1
-	github.com/sirupsen/logrus v1.4.2
-	github.com/spf13/cobra v0.0.5
-	github.com/spiral/broadcast v0.0.0-20191206140608-766959683e74
-	github.com/spiral/roadrunner v1.5.2
-	github.com/stretchr/testify v1.3.0
+	github.com/gorilla/websocket v1.4.2
+	github.com/prometheus/client_golang v1.7.1
+	github.com/sirupsen/logrus v1.6.0
+	github.com/spf13/cobra v1.0.0
+	github.com/spiral/broadcast/v2 v2.0.5-beta.1
+	github.com/spiral/roadrunner v1.9.2
+	github.com/stretchr/testify v1.6.1
 )

service.go

@@ -7,7 +7,7 @@ import (
 	"sync/atomic"
 
 	"github.com/gorilla/websocket"
-	"github.com/spiral/broadcast"
+	"github.com/spiral/broadcast/v2"
 	"github.com/spiral/roadrunner/service/env"
 	rhttp "github.com/spiral/roadrunner/service/http"
 	"github.com/spiral/roadrunner/service/rpc"

service_test.go

@@ -12,7 +12,7 @@ import (
 	"github.com/gorilla/websocket"
 	"github.com/sirupsen/logrus"
 	"github.com/sirupsen/logrus/hooks/test"
-	"github.com/spiral/broadcast"
+	"github.com/spiral/broadcast/v2"
 	"github.com/spiral/roadrunner/service"
 	"github.com/spiral/roadrunner/service/env"
 	rrhttp "github.com/spiral/roadrunner/service/http"