Method Pull

sbuf/batch.go:77–101

(done bool)

}

func (p *puller) Pull(done bool) (Batch, error) {
	if done {
		p.zr = nil
	}
	if p.zr == nil {
		return nil, nil
	}
	batch := newPullerBatch()
	for {
		val, err := p.zr.Read()
		if err != nil {
			return nil, err
		}
		if val == nil {
			p.zr = nil
			if len(batch.vals) == 0 {
				return nil, nil
			}
			return batch, nil
		}
		if batch.appendVal(*val) {
			return batch, nil
		}
	}
}

type pullerBatch struct {
	buf  []byte