code: func (qs *queryResponseStream) sendDone() error {
  	header := responseHeader{
  		Seq:   qs.seq,
  		Error: "",
  	}
  	rec := queryRecord{
  		Type: queryRecordDone,
  	}
  	return qs.client.Send(&header, &rec)
  }
docs: // sendDone is used to signal the end