func()

in pubsub.go [251:272]

• 19 lines of code
• 5 McCabe index (conditional complexity)

func (p *Pubsub) resubscribe(cnx net.Conn) {
	p.mu.Lock()
	p.connection = cnx

	if len(p.channels) > 0 {
		cmd := NewRequest(commandSubscribe, len(p.channels))
		for channel := range p.channels {
			cmd.Bulk([]byte(channel))
		}
		p.commandSync(cmd)
	}

	if len(p.patterns) > 0 {
		cmd := NewRequest(commandPSubscribe, len(p.patterns))
		for pattern := range p.patterns {
			cmd.Bulk([]byte(pattern))
		}
		p.commandSync(cmd)
	}

	p.mu.Unlock()
}