Merge pull request #24 from cfconrad/fix_queue

Fix ReadWriteProcess::Queue as regression of 1e0addb

Author: foursixnine

lib/Mojo/IOLoop/ReadWriteProcess.pm

@@ -148,6 +148,7 @@ sub _collect {
   my ($self, $pid) = @_;
   $pid //= $self->pid;
 
+  $self->session->consume_collected_info;
   $self->session->_protect(
     sub {
       local $?;

lib/Mojo/IOLoop/ReadWriteProcess/Queue.pm

@@ -28,6 +28,7 @@ sub consume {
     $self->queue->maximum_processes + $self->pool->maximum_processes);
   until ($self->exhausted) {
     sleep .5;
+    $self->session->consume_collected_info;
     $self->session->_protect(
       sub {
         $self->pool->each(