File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -487,11 +487,11 @@ func (c *PubSub) getContext() context.Context {
487487
488488// Channel returns a Go channel for concurrently receiving messages.
489489// The channel is closed together with the PubSub. If the Go channel
490- // is blocked full for 30 seconds the message is dropped.
490+ // is blocked full for 1 minute the message is dropped.
491491// Receive* APIs can not be used after channel is created.
492492//
493493// go-redis periodically sends ping messages to test connection health
494- // and re-subscribes if ping can not not received for 30 seconds .
494+ // and re-subscribes if ping can not not received for 1 minute .
495495func (c * PubSub ) Channel (opts ... ChannelOption ) <- chan * Message {
496496 c .chOnce .Do (func () {
497497 c .msgCh = newChannel (c , opts ... )
You can’t perform that action at this time.
0 commit comments