code: func newReadPump(cnx redis.Conn) *readPump {
  	return &readPump{
  		cnx:    cnx,
  		data:   make(chan interface{}),
  		errs:   make(chan error),
  		closer: make(chan struct{}),
  	}
  }
docs: // newReadPump creates a new pump that operates on the single Redis connection.