diff --git a/lib/Gearman/Task.pm b/lib/Gearman/Task.pm
index 94ee9bf..983cc5d 100644
--- 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