X-Git-Url: http://git.rot13.org/?a=blobdiff_plain;f=t%2F06-queue.t;h=e56b93e89deb4d037567177246a6324c93a3b03c;hb=fec1acf5d1dfce1a661535d2b40b0e9d97de6005;hp=e8cfe3e6a986b836249797c82ec42f8043728f4a;hpb=ca6ef25dcfcb37bd49839770139c8568de69471c;p=perl-cwmp.git

diff --git a/t/06-queue.t b/t/06-queue.t
index e8cfe3e..e56b93e 100755
--- a/t/06-queue.t
+++ b/t/06-queue.t
@@ -4,7 +4,7 @@ use warnings;
 
 my $debug = shift @ARGV;
 
-use Test::More tests => 129;
+use Test::More tests => 213;
 use Data::Dump qw/dump/;
 use lib 'lib';
 
@@ -23,16 +23,18 @@ ok( my $obj = CWMP::Queue->new({
 isa_ok( $obj, 'CWMP::Queue' );
 
 for my $i ( 1 .. 42 ) {
-	ok( $obj->enqueue(
+	ok( $obj->enqueue({
 		i => $i,
 		foo => 'bar',
-	), "enqueue $i" );
+	}), "enqueue $i" );
 };
 
 my $i = 1;
 
-while ( my $data = $obj->dequeue ) {
-	ok( $data, "dequeue $i" );
-	cmp_ok( $data->{i}, '==', $i, "i == $i" );
+while ( my $job = $obj->dequeue ) {
+	ok( $job, "dequeue $i" );
+	ok( my $dispatch = $job->dispatch, "dispatch $i" );
+	cmp_ok( $dispatch->{i}, '==', $i, "i == $i" );
+	ok( $job->finish, "finish $i" );
 	$i++;
 }