t/worker.t

   1 #!/usr/bin/env perl
   2 use warnings;
   3 use strict;
   4
   5 use Test::More tests => 6;
   6 use Data::Dump qw(dump);
   7 use lib 'lib';
   8
   9 use_ok 'MojoX::Gearman';
  10
  11 my $g = new_ok 'MojoX::Gearman';
  12
  13 my $name = "mojo_g";
  14 ok( my $can_do = $g->req( 'CAN_DO', $name, sub {
  15         my $payload = shift;
  16         warn "DO $name ", dump($payload), $/;
  17         return $payload + 1;
  18 }), "CAN_DO $name" );
  19 diag $can_do;
  20
  21 ok( $g->req( 'CAN_DO', "mojo_rev", sub { reverse shift } ), 'mojo_rev' );
  22
  23 diag "start loop";
  24 ok( $g->req( 'GRAB_JOB' ), 'GRAB_JOB' );
  25 ok( $g->start, 'start' ) for ( 1 .. 2 );
  26