File Coverage

blib/lib/Dallycot/AST/BuildList.pm

Criterion	Covered	Total	%
statement	18	45	40.0
branch	0	2	0.0
condition			n/a
subroutine	6	12	50.0
pod	0	2	0.0
total	24	61	39.3

package Dallycot::AST::BuildList;
our $AUTHORITY = 'cpan:JSMITH';

# ABSTRACT: Create stream-like collection with possible generator

use strict;
use warnings;

use utf8;
use parent 'Dallycot::AST';

use experimental qw(switch);

use Promises qw(deferred);

sub to_rdf {
  my($self, $model) = @_;

  return $model -> apply(
    $model -> meta_uri('loc:build-list'),
    [ @$self ],
    {}
  );
  # my $bnode = $model -> bnode;
  # $model -> add_type($bnode, 'loc:List');
  # if(@$self) {
  #   $model -> add_list($bnode, 'loc:expressions',
  #     map { $_ -> to_rdf($model) } @$self
  #   );
  # }

  # return $bnode;
}

sub execute {
  my ( $self, $engine ) = @_;

  my $d = deferred;

  my @expressions = @$self;
  given ( scalar(@expressions) ) {
    when (0) {
      $d->resolve( Dallycot::Value::EmptyStream->new );
    }
    when (1) {
      $engine->execute( $self->[0] )->done(
        sub {
          my ($result) = @_;
          $d->resolve( Dallycot::Value::Stream->new($result) );
        },
        sub {
          $d->reject(@_);
        }
      );
    }
    default {
      my $last_expr = pop @expressions;
      my $promise;
      if ( $last_expr->isa('Dallycot::Value') ) {
        push @expressions, $last_expr;
      }
      else {
        $promise = $engine->make_lambda($last_expr);
      }
      $engine->collect(@expressions)->done(
        sub {
          my (@items) = @_;
          my $result = Dallycot::Value::Stream->new( ( pop @items ), undef, $promise );
          while (@items) {
            $result = Dallycot::Value::Stream->new( ( pop @items ), $result );
          }
          $d->resolve($result);
        },
        sub {
          $d->reject(@_);
        }
      );
    }
  }

  return $d->promise;
}

1;