view release on metacpan or  search on metacpan

t/02-timeouts.t  view on Meta::CPAN

} elsif ($pid) {
  # parent
  $pipe->reader;
  my $cv = AnyEvent->condvar;
  my $dev = AnyEvent::CurrentCost->new(filehandle => $pipe,
                                       discard_timeout => 0.5,
                                       callback => sub { $cv->send($_[0]) });
  my $msg = $cv->recv;
  is($msg->value, 1380, 'first value');
  $cv = AnyEvent->condvar;
  AnyEvent->timer(after => 1.5, sub { $cv->send });
  warning_like { $msg = $cv->recv }
    {carped => qr/Discarding '<msg><src>truncated'/}, 'discard timeout';
  is($msg->value, 1999, 'second value');

  waitpid $pid, 0;
} else {
  die $!;
}

sub test_error {