From 220f1976f0fddbc168652d340183bbdbb1745951 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Fri, 21 Apr 2023 11:58:16 +0200 Subject: [PATCH] api/redis/subscriber.go: remove client field from Subscriber struct --- api/redis/subscriber.go | 2 -- api/redis/subscriber_test.go | 1 - 2 files changed, 3 deletions(-) diff --git a/api/redis/subscriber.go b/api/redis/subscriber.go index 2efd98f..b563d64 100644 --- a/api/redis/subscriber.go +++ b/api/redis/subscriber.go @@ -11,7 +11,6 @@ import ( ) type Subscriber struct { - client *redis.Client sub *redis.PubSub ctx context.Context mu sync.RWMutex @@ -30,7 +29,6 @@ func WithTimeout(value time.Duration) SubscriberOption { func NewSubscriber(client *redis.Client, ns Namespace, options ...SubscriberOption) *Subscriber { sub := &Subscriber{ - client: client, ctx: client.Context(), sub: client.PSubscribe(client.Context()), channels: make(map[string]chan []byte), diff --git a/api/redis/subscriber_test.go b/api/redis/subscriber_test.go index 27e4899..14c05be 100644 --- a/api/redis/subscriber_test.go +++ b/api/redis/subscriber_test.go @@ -18,7 +18,6 @@ func TestSubscriber_Construct(t *testing.T) { s := NewSubscriber(client, ns) - assert.Equal(t, s.client, client) assert.Equal(t, s.ctx, client.Context()) assert.NotNil(t, s.sub) assert.Equal(t, s.ns, ns)