From e053f7eaf34dd1b1abb7a3c8cdefca1e004eaf56 Mon Sep 17 00:00:00 2001 From: Sergey Kozlov Date: Mon, 30 Oct 2023 16:35:02 +0400 Subject: [PATCH] update PubSub.Channel documentation (#2761) Co-authored-by: ofekshenawa <104765379+ofekshenawa@users.noreply.github.com> --- pubsub.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pubsub.go b/pubsub.go index 16c0f5672..5df537c42 100644 --- a/pubsub.go +++ b/pubsub.go @@ -487,11 +487,11 @@ func (c *PubSub) getContext() context.Context { // Channel returns a Go channel for concurrently receiving messages. // The channel is closed together with the PubSub. If the Go channel -// is blocked full for 30 seconds the message is dropped. +// is blocked full for 1 minute the message is dropped. // Receive* APIs can not be used after channel is created. // // go-redis periodically sends ping messages to test connection health -// and re-subscribes if ping can not not received for 30 seconds. +// and re-subscribes if ping can not not received for 1 minute. func (c *PubSub) Channel(opts ...ChannelOption) <-chan *Message { c.chOnce.Do(func() { c.msgCh = newChannel(c, opts...)