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 {
487
487
488
488
// Channel returns a Go channel for concurrently receiving messages.
489
489
// 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.
491
491
// Receive* APIs can not be used after channel is created.
492
492
//
493
493
// 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 .
495
495
func (c * PubSub ) Channel (opts ... ChannelOption ) <- chan * Message {
496
496
c .chOnce .Do (func () {
497
497
c .msgCh = newChannel (c , opts ... )
You can’t perform that action at this time.
0 commit comments