File Coverage

blib/lib/Event/Distributor/Query.pm

Criterion	Covered	Total	%
statement	32	32	100.0
branch	7	8	87.5
condition	2	3	66.6
subroutine	8	8	100.0
pod	1	1	100.0
total	50	52	96.1

#  You may distribute under the terms of either the GNU General Public License
#  or the Artistic License (the same terms as Perl itself)
#
#  (C) Paul Evans, 2014-2017 -- [e-mail]

package Event::Distributor::Query;

use strict;
use warnings;
use base qw( Event::Distributor::_Event );

our $VERSION = '0.05';

use Future;

=head1 NAME

C - an event that collects a result

=head1 DESCRIPTION

This subclass of L invokes each of its subscribers
in turn, yielding either the (first) successful and non-empty result, or a
failure if they all fail. Yields a (successful) empty result if there are no
subscribers.

=cut

sub fire
{
   my $self = shift;
   my ( $dist, @args ) = @_;

   my $await = $self->{await};
   my @f;

   foreach my $sub ( $self->subscribers ) {
      my $f = $sub->( $dist, @args )->then_with_f( sub {
         my $f = shift;
         return $f if @_;
         die "No result\n";
      });

      push @f, $f;

      last if $f->is_ready and !$f->failure;
   }

   return Future->done if !@f;

   return Future->needs_any( @f )->then( sub {
      my @results = @_;
      # TODO: conversions?
      Future->done( @results );
   })->else_with_f( sub {
      my $f = shift;
      my @other_fails = grep { $_->failure ne "No result\n" } $f->failed_futures;

      return $other_fails[0] if @other_fails;
      Future->done();
   });
}

=head1 AUTHOR

Paul Evans

=cut

0x55AA