code: func (r *QueryResponse) Close() {
  	r.closeLock.Lock()
  	defer r.closeLock.Unlock()
  	if r.closed {
  		return
  	}
  	r.closed = true
  	if r.ackCh != nil {
  		close(r.ackCh)
  	}
  	if r.respCh != nil {
  		close(r.respCh)
  	}
  }
docs: // Close is used to close the query, which will close the underlying
  // channels and prevent further deliveries