impl_->pendingLimit_ = pendingLimit;
modules->notifyParallelDataStart(data, options);
// Data needs to be set before calling extendBuffer()
impl_->pendingLimit_ = pendingLimit;
modules->notifyParallelDataStart(data, options);
// Data needs to be set before calling extendBuffer()