view release on metacpan or  search on metacpan

FCP.pm  view on Meta::CPAN

      @_,
      queue      => [],
      req        => {},
      prefix     => "..:aefcpid:$rand:",
      idseq      => "a0",
   }, $class;

   {
      Scalar::Util::weaken (my $self = $self);

      $self->{kw} = AE::timer $self->{keepalive}, $self->{keepalive}, sub {
         $self->{hdl}->push_write ("\n");
      };

      our $ENDMESSAGE = qr<\012(EndMessage|Data)\012>;

      # these are declared here for performance reasons
      my ($k, $v, $type);
      my $rdata;
         
      my $on_read = sub {

eg/f7progress  view on Meta::CPAN

   shift @log
      while @log > $log;

   addstr $y++, 0, $_
      for @log;

   refresh;
}

my $w = AE::timer 10, 10, \&updater;

my $fcp = new AnyEvent::FCP progress => sub {
   my ($fcp, $type, $kv, $rdata) = @_;

   delete $kv->{pkt_type};
   (my $id = delete $kv->{identifier}) =~ s/^FProxy://;

   if ($type eq "simple_progress") {
      my $progress = sprintf "%5d / %5d, %3d%%", $kv->{succeeded}, $kv->{required}, 100 * $kv->{succeeded} / $kv->{required};
      $progress = $kv->{finalized_total} eq "true" ? " $progress " : "($progress)";