1 files changed, 34 insertions, 0 deletions
diff --git a/plugins/broadcast/ws/subscriber.go b/plugins/broadcast/ws/subscriber.go
index 98592950..2039cf95 100644
--- a/plugins/broadcast/ws/subscriber.go
+++ b/plugins/broadcast/ws/subscriber.go
@@ -1 +1,35 @@
 package ws
+
+import "github.com/spiral/roadrunner/v2/plugins/broadcast"
+
+type Subscriber struct {
+	connections map[string]*Connection
+	storage broadcast.Storage
+}
+
+func NewWSSubscriber() (broadcast.Subscriber, error) {
+	m := make(map[string]*Connection)
+	return &Subscriber{
+		connections: m,
+	}, nil
+}
+
+func (s *Subscriber) Subscribe(upstream chan *broadcast.Message, topics ...string) error {
+	panic("implement me")
+
+
+
+
+}
+
+func (s *Subscriber) SubscribePattern(upstream chan *broadcast.Message, pattern string) error {
+	panic("implement me")
+}
+
+func (s *Subscriber) Unsubscribe(upstream chan *broadcast.Message, topics ...string) error {
+	panic("implement me")
+}
+
+func (s *Subscriber) UnsubscribePattern(upstream chan *broadcast.Message, pattern string) error {
+	panic("implement me")
+}