in client/rpcdataset.go [417:436]
func (s *IoTDBRpcDataSet) next() (bool, error) {
if s.closed {
return false, errClosed
}
if s.hasCachedResults() {
s.constructOneRow()
return true, nil
}
if s.emptyResultSet {
return false, nil
}
r, err := s.fetchResults()
if err == nil && r {
s.constructOneRow()
return true, nil
}
return false, nil
}