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