code: func (mbc *Receiver) Cut() []*cb.Envelope {
  	mbc.mutex.Lock()
  	defer mbc.mutex.Unlock()
  	logger.Debugf("Cutting batch")
  	res := mbc.curBatch
  	mbc.curBatch = nil
  	return res
  }
docs: // Cut terminates the current batch, returning it