Fix limit transfrom prepare.

This commit is contained in:
Nikolai Kochetov 2019-04-12 17:49:34 +03:00
parent 5aa3d98ea2
commit 9c5d555e69

View File

@ -120,13 +120,7 @@ LimitTransform::Status LimitTransform::prepare()
output.push(std::move(current_chunk));
has_block = false;
if (input.isFinished())
{
output.finish();
return Status::Finished;
}
return Status::NeedData;
return Status::PortFull;
}
/// No more data is needed.