PubSubConn.ReceiveWithTimeout allways has Error

[brucelin-cn]

func runRecv(mq *MessageQueue) {
	conn := mq.pool.Get()
	defer conn.Close()
	tmp := rand.Intn(1000000000)
	var runningErr error
	psc := redis.PubSubConn{Conn: conn}
	for {

		v := psc.ReceiveWithTimeout(100 * time.Millisecond)
		switch msg := v.(type) {
		case redis.Message:
			log.Info("Message", tmp, msg.Channel, msg.Data)
			mq.broadcastMessage(msg.Channel, msg.Data)
		case redis.Subscription:
			
			log.Info("Subscription change:%v %s: %s %d\n", tmp, msg.Kind, msg.Channel, msg.Count)
		case error:

			if msg != nil {
				if nErr, ok := msg.(net.Error); ok && nErr.Timeout() {			

					log.Error("Redis Timeout error:", tmp, msg, conn.Err())
					if err := psc.Subscribe("foo"); err != nil {
						log.Info("Ping failed:", err)
						runningErr = err
					}
					continue
				} else {
					
					runningErr = msg
					log.Error("Redis error:", tmp, msg, conn.Err(), runningErr)

				}
			}

		}

	}
}

During the second loop, the error "use of closed network connection" keeps occurring. at line：log.Error("Redis error:", xxxx）

maybe there is some bugs here?

func (c *conn) ReceiveWithTimeout(timeout time.Duration) (reply interface{}, err error) {
      //  should be check is Timeout Err?
	if reply, err = c.readReply(); err != nil {
		return nil, c.fatal(err)
	}
     //

}