push @waiting, [$host, $self->fetch($host, $group)];
}
$self->_log("Now waiting for results");
- my @results = map {
+ for my $wait (@waiting) {
my ($host, @futures) = @$_;
- my $done = [$host, await_all @futures];
+ my @data = await_all @futures;
$self->_log("Received all from group '$group' on '$host'");
- $done;
- } @waiting;
- $self->_log("All gathered for group '$group'");
- for my $result (@results) {
- my ($host, @data) = @$result;
$self->_store($host, $group, +{ map %$_, @data });
}
}