Read timeout and connection closing about redigo HOT 2 CLOSED

package main

import (
    "github.com/garyburd/redigo/redis"
    "log"
    "sync"
)

func main() {
    var wg sync.WaitGroup

    conn, err := redis.DialTimeout("tcp", "localhost:6379", 0, 0, 0)  // read timeout is zero
    if err != nil {
        log.Fatal(err)
    }

    pubsub := redis.PubSubConn{conn}
    pubsub.Subscribe("x")

    wg.Add(1)
    go func() {
        defer wg.Done()

        for {
            switch m := pubsub.Receive().(type) {
            case redis.Message:
                log.Println("Message:", m)
            case redis.Subscription:
                if m.Count == 0 {
                    log.Println("Done")
                    return
                }
            case error:
                log.Println("Error:", m)
                return
            }
        }
    }()

    // unsubscribe all to end loop
    pubsub.Unsubscribe()

    // wait for goroutine to exit
    wg.Wait()
}