eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-17 04:30:03 +02:00
Code Releases Activity

transport/redis_pubsub/subscriber.go: make Close() return an error.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-29 15:40:37 +02:00
parent a23661e088
commit 65173425a6
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
transport/redis_pubsub/subscriber.go
View file

@ -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
}