AnyEvent-Filesys-Watcher

 view release on metacpan or  search on metacpan

lib/AnyEvent/Filesys/Watcher/Fallback.pm  view on Meta::CPAN

use Scalar::Util qw(weaken);

use base qw(AnyEvent::Filesys::Watcher);

sub new {
	my ($class, %args) = @_;

	my $self = $class->SUPER::_new(%args);

	my $alter_ego = $self;
	my $impl = AnyEvent->timer(
		after => $self->interval,
		interval => $self->interval,
		cb => sub {
			$alter_ego->_processEvents();
		}
	);
	weaken $alter_ego;

	if (!$impl) {
		die __x("Error creating timer: {error}\n", error => $@);
	}

	$self->_watcher($impl);

	return $self;
}

1;

t/34-raw-events.t  view on Meta::CPAN

			$done->send if @raw >= 3;
			return @_;
		},
		%extra_config,
	);
	isa_ok $n, 'AnyEvent::Filesys::Watcher';

	# Create a file, which will be delete in the callback
	create_test_files 'foo', 'bar', 'baz';

	my $timer = AnyEvent->timer(
		after => 5,
		cb => sub {
			ok 0, "lame test";
			$done->send;
		}
	);

	$done->recv;
	ok scalar @raw >= 3, 'at least 3 events received';
}

t/41-bug-modified-in-cb.t  view on Meta::CPAN

				}
			}
		},
		%extra_config,
	);
	isa_ok $n, 'AnyEvent::Filesys::Watcher';

	# Create a file, which will be delete in the callback
	create_test_files 'foo';

	my $timer = AnyEvent->timer(
		after => 5,
		cb => sub {
			ok 0, "lame test";
			$done->send;
		}
	);

	$done->recv;

	my $created_seen;

t/lib/TestSupport.pm  view on Meta::CPAN

		backend => $args{backend},
		parse_events => 1,
		skip_subdirectories => $args{skip_subdirectories},
	);

	$args{setup}->();

	my $done = AnyEvent->condvar;

	my $count = 0;
	my $timer = AnyEvent->timer(
		interval => 0.1,
		cb => sub {
			$done->send if test_done \@received, $args{expected};
			if (++$count > 30) {
				ok 0, "$args{description}: lame test\n";
				$done->send;
			}
		},
	);