File Coverage

blib/lib/Mojo/File/ChangeNotify/WatcherProcess.pm

Criterion	Covered	Total	%
statement	14	23	60.8
branch	0	2	0.0
condition			n/a
subroutine	5	6	83.3
pod	0	1	0.0
total	19	32	59.3

package Mojo::File::ChangeNotify::WatcherProcess 0.02;
use 5.020;
use experimental 'signatures';
use feature 'postderef';
use Exporter 'import';
use File::ChangeNotify;
our @EXPORT_OK = 'watch';

# We keep this in a separate module file as to minimize any variables
# shared over into this context

=head1 NAME

Mojo::File::ChangeNotify::WatcherProcess - helper module for the subprocess

=head1 SYNOPSIS

  my $w = Mojo::File::ChangeNotify->instantiate_watcher(
      directories => ['.'],
      on_change => sub($s,$ev) {
          for my $e ($ev->@*) {
            print "$e->{type} $e->{path}\n";
          }
      }
  );
  # note that the watcher might need about 1s to start up

=cut

sub watch( $subprocess, $args ) {
    my $watcher = File::ChangeNotify->instantiate_watcher( $args->%* );
    while( my @events = $watcher->wait_for_events ) {
        for my $list (@events) {
            $subprocess->progress( [ map {;
                                       defined $_->path
                                       ? +{ path => $_->path, type => $_->type }
                                       : ()
                                     } $list ]);
        }
    }
}

1;