code: func (c *streamClient) closeConn() {
  	conn := c.decoupleConn()
  	if conn != nil {
  		if err := conn.Close(); err != nil {
  			log.Fields{
  				log.ErrorKey: err,
  			}.Warningf(c, "Error on connection close.")
  		}
  	}
  }
docs: // Closes the underlying connection.