onBatchEnd method

@override void onBatchEnd()

Called from endBatch. Does nothing by default: for sinks that handle each entry in onAdd; wrappers (DelegatingSink) pass the end of batch to inner.

Implementation

@override
void onBatchEnd() {
  if (_currentBatch.isEmpty) return;
  batches.add(_currentBatch);
  _currentBatch = [];
}