(done bool)
| 93 | } |
| 94 | |
| 95 | func (d *Dematerializer) Pull(done bool) (vector.Any, error) { |
| 96 | return d.ConcurrentPull(done, 0) |
| 97 | } |
| 98 | |
| 99 | func (d *Dematerializer) ConcurrentPull(done bool, _ int) (vector.Any, error) { |
| 100 | d.mu.Lock() |
no test coverage detected