Searched defs:floatParallelIterator (Results 1 – 4 of 4) sorted by relevance
584 type floatParallelIterator struct { struct585 input FloatIterator586 ch chan floatPointError588 once sync.Once589 closing chan struct{}590 wg sync.WaitGroup606 func (itr *floatParallelIterator) Stats() IteratorStats { return itr.input.Stats() }609 func (itr *floatParallelIterator) Close() error {616 func (itr *floatParallelIterator) Next() (*FloatPoint, error) {625 func (itr *floatParallelIterator) monitor() {