Task got on_data field

(borrowed gearman/perl-Gearman-Client#4)
p-alik · Oct 27, 2016 · 4ef1954 · 4ef1954
1 parent 5e20b17
commit 4ef1954
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/lib/Gearman/Task.pm b/lib/Gearman/Task.pm
@@ -121,6 +121,7 @@ use fields (
     # opts from client:
     'uniq',
     'on_complete',
+    'on_data',
     'on_fail',
     'on_exception',
     'on_retry',
@@ -416,6 +417,18 @@ sub status {
     $self->{on_status}->($nu, $de);
 } ## end sub status
 
+=head2 data()
+
+=cut
+
+sub data {
+    my Gearman::Task $task = shift;
+    return if $task->{is_finished};
+    my $result_ref = shift;
+
+    $task->{on_data}->($result_ref) if $task->{on_data};
+} ## end sub data
+
 =head2 handle()
 
 getter