File Coverage

lib/Flux/Simple.pm

Criterion	Covered	Total	%
statement	26	26	100.0
branch	1	2	50.0
condition			n/a
subroutine	9	9	100.0
pod	3	3	100.0
total	39	40	97.5

package Flux::Simple;
{
  $Flux::Simple::VERSION = '1.03';
}

# ABSTRACT: functional-style stream generators


use strict;
use warnings;

use Flux::Simple::ArrayIn;
use Flux::Simple::ArrayOut;
use Flux::Mapper::Anon;

use parent qw(Exporter);
our @EXPORT_OK = qw( array_in array_out mapper );

sub array_in {
    my ($arrayref) = @_;
    return Flux::Simple::ArrayIn->new($arrayref);
}

sub array_out {
    my ($arrayref) = @_;
    return Flux::Simple::ArrayOut->new($arrayref);
}

sub mapper(&;&) {
    my ($cb, $commit_cb) = @_;

    my @args = (cb => $cb);
    push @args, commit_cb => $commit_cb if defined $commit_cb;
    return Flux::Mapper::Anon->new(@args);
}


1;

__END__