File Coverage

blib/lib/Directory/Scanner/API/Stream.pm

Criterion	Covered	Total	%
statement	26	29	89.6
branch			n/a
condition			n/a
subroutine	8	9	88.8
pod	6	6	100.0
total	40	44	90.9

package Directory::Scanner::API::Stream;
# ABSTRACT: Streaming directory iterator abstract interface

use strict;
use warnings;

our $VERSION   = '0.04';
our $AUTHORITY = 'cpan:STEVAN';

sub head;

sub is_done;
sub is_closed;

sub close;
sub next;

sub clone; # ( $dir => Path::Tiny )

## ...

sub flatten {
	my ($self) = @_;
	my @results;
	while ( my $next = $self->next ) {
		push @results => $next;
	}
	return @results;
}

# IMPORTANT NOTE:
# We have a bit of a recursive dependency issue here, which
# is that these methods are being defined here as calls to
# other classes, all of which also `do` this role. This means
# that we need to lazy load things here so as to avoid load
# ordering issues elsewhere.

sub recurse {
    my ($self) = @_;
    require Directory::Scanner::Stream::Recursive;
    Directory::Scanner::Stream::Recursive->new( stream => $self );
}

sub ignore {
    my ($self, $filter) = @_;
    require Directory::Scanner::Stream::Ignoring;
    Directory::Scanner::Stream::Ignoring->new( stream => $self, filter => $filter );
}

sub match {
    my ($self, $predicate) = @_;
    require Directory::Scanner::Stream::Matching;
    Directory::Scanner::Stream::Matching->new( stream => $self, predicate => $predicate );
}

sub apply {
    my ($self, $function) = @_;
    require Directory::Scanner::Stream::Application;
    Directory::Scanner::Stream::Application->new( stream => $self, function => $function );
}

sub transform {
    my ($self, $transformer) = @_;
    require Directory::Scanner::Stream::Transformer;
    Directory::Scanner::Stream::Transformer->new( stream => $self, transformer => $transformer );
}

## ...

# shhh, I shouldn't do this
sub _log {
	my ($self, @msg) = @_;
    warn( @msg, "\n" );
    return;
}

1;

__END__