diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-18 00:27:08 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-18 00:27:08 +0300 |
| commit | 300560b44451bd9d5241ccdbaea3576760968ef2 (patch) | |
| tree | 88d7d862707ae135f8c345e59111f2b2b9dff60f /plugins/redis/pubsub/channel.go | |
| parent | 65a70f5d15fb0a1b1f787ff7f06b3a299dab0f96 (diff) | |
Update broadcast tests, improve stop mechanism.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/redis/pubsub/channel.go')
| -rw-r--r-- | plugins/redis/pubsub/channel.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/redis/pubsub/channel.go b/plugins/redis/pubsub/channel.go index eef5a7b9..a1655ab2 100644 --- a/plugins/redis/pubsub/channel.go +++ b/plugins/redis/pubsub/channel.go @@ -92,6 +92,6 @@ func (r *redisChannel) stop() error { return nil } -func (r *redisChannel) message() *pubsub.Message { - return <-r.out +func (r *redisChannel) message() chan *pubsub.Message { + return r.out } |