From 65173425a6d0f1659422579d24eaee5586658fb5 Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik@eossweden.org>
Date: Wed, 29 Mar 2023 15:40:37 +0200
Subject: [PATCH] transport/redis_pubsub/subscriber.go: make Close() return an
 error.

---
 transport/redis_pubsub/subscriber.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/transport/redis_pubsub/subscriber.go b/transport/redis_pubsub/subscriber.go
index 4a14b88..8fccb9b 100644
--- a/transport/redis_pubsub/subscriber.go
+++ b/transport/redis_pubsub/subscriber.go
@@ -96,8 +96,8 @@ func (s *Subscriber) Read(channel transport.Channel) ([]byte, error) {
 	return <-ch, nil
 }
 
-func (s *Subscriber) Close() {
-	s.sub.Close()
+func (s *Subscriber) Close() error {
+	err := s.sub.Close()
 
 	for _, ch := range s.channels {
 		close(ch)
@@ -105,4 +105,6 @@ func (s *Subscriber) Close() {
 	s.mu.Lock()
 	s.channels = make(map[string]chan []byte)
 	s.mu.Unlock()
+
+	return err
 }