Presumably you're referring to this section in _multi_rpc() which needs to change?:

my @responses; my $remaining = $num_shards; my $select = $select{$$self}; my $sock_map = $sock_map{$$self}; while ($remaining) { my @ready = $select->can_read; for my $sock ( @{ $ready[0] } ) { my $shard_num = $sock_map->{"$sock"}; my $response = $self->_retrieve_response_from_shard($shard_num); $responses[$shard_num] = $response->{retval}; $remaining--; } }