We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b88fd4f commit f920bd3Copy full SHA for f920bd3
1 file changed
lib/Mojo/IOLoop/ReadWriteProcess/Queue.pm
@@ -28,6 +28,7 @@ sub consume {
28
$self->queue->maximum_processes + $self->pool->maximum_processes);
29
until ($self->exhausted) {
30
sleep .5;
31
+ $self->session->consume_collected_info;
32
$self->session->_protect(
33
sub {
34
$self->pool->each(
0 commit comments