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)