Description
See PHOENIX-1435 for test case. In the case of a work being rejected, we have to make sure to close all PeekingResultIterators that were already put on the queue.
See PHOENIX-1435 for test case. In the case of a work being rejected, we have to make sure to close all PeekingResultIterators that were already put on the queue.