From 1de6cd94321e48430f9ec08f9aa5313f0854b0c5 Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik@eossweden.org>
Date: Wed, 29 Mar 2023 11:51:15 +0200
Subject: [PATCH] transport/redis_pubsub/publisher.go: Adding Close() method.

---
 transport/redis_pubsub/publisher.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/transport/redis_pubsub/publisher.go b/transport/redis_pubsub/publisher.go
index 599ba1c..1625ab8 100644
--- a/transport/redis_pubsub/publisher.go
+++ b/transport/redis_pubsub/publisher.go
@@ -31,3 +31,7 @@ func (r *Publisher) Flush() error {
 	_, err := r.pipeline.Exec(r.ctx)
 	return err
 }
+
+func (r *Publisher) Close() error {
+	return r.pipeline.Close()
+}