Yet Another CPAN Grep

MooseX-POE ( G/GE/GETTY/MooseX-POE-0.215.tar.gz, GETTY, 2012; MetaCPAN )

MooseX-POE/ex/tbray/tbray_poe_workers.pl ( view source; MetaCPAN )

b} <=> $count->{$a} } keys %$count;
    };

}

{

    package Count;
    use MooseX::POE;
    use JSON::Any qw(XS);
    with qw(MooseX::Workers);

    my $rx = qr|GET /ongoing/When/\d\d\dx/(\d\d\d\d/\

nk) {
                    $count->{$1}++ if $line =~ $rx;
                }
                print JSON::Any->encode(
                    { sender => $sender->ID, count => $count } );
            }

r => 'loop' );
    };

    sub worker_stdout {
        my ( $self, $out ) = @_;
        my $msg = JSON::Any->decode($out);
        POE::Kernel->post( $msg->{sender} => 'inc' => $msg->{count} );
    }

MooseX-POE ( G/GE/GETTY/MooseX-POE-0.215.tar.gz, GETTY, 2012; MetaCPAN )

MooseX-POE/ex/tbray/tbray_coro_workers.pl ( view source; MetaCPAN )

 };
    __PACKAGE__->meta->make_immutable;
}

{

    package Count;
    use MooseX::Coro;
    use JSON::Any qw(XS);
    with qw(MooseX::Workers);

    sub BUILD { POE::Kernel->run }

    has sender =>

              print JSON::Any->encode($count);
            }
        );
    };

    sub worker_stdout {
        my ( $self, $out ) = @_;
        warn $out;
        my $count = JSON::Any->decode($out);