1 files changed, 10 insertions, 10 deletions

diff --git a/lib/Thread/Task/Handle.pm b/lib/Thread/Task/Handle.pm
index b7012f4..5dfcd40 100644
--- a/lib/Thread/Task/Handle.pm
+++ b/lib/Thread/Task/Handle.pm
@@ -4,7 +4,7 @@ use MooseX::Declare;
 class Thread::Task::Handle {
     use TryCatch;
 
-    use MooseX::Types::Moose qw(Object Bool Int);
+    use MooseX::Types::Moose qw(ClassName Int ArrayRef);
     use Thread::Task::Types qw(Handle_T Worker_T Task_T Finished_ET);
     use Thread::Task::Exception::Finished;
 
@@ -36,8 +36,8 @@ class Thread::Task::Handle {
         try {
             $self->task->prepare;
         }
-        catch (Finished_ET) {
-            die $@;
+        catch (Finished_ET $e) {
+            die $e;
         }
         catch {
             die Thread::Task::Exception::Finished->new(msg=>$@);
@@ -48,8 +48,8 @@ class Thread::Task::Handle {
         try {
             $self->task->finish;
         }
-        catch (Finished_ET) {
-            die $@;
+        catch (Finished_ET $e) {
+            die $e;
         }
         catch {
             die Thread::Task::Exception::Finished->new(msg=>$@);
@@ -62,7 +62,7 @@ class Thread::Task::Handle {
             $self->task->run;
             $self->task->clear_handle;
         }
-        catch (Finished_ET) {
+        catch (Finished_ET $e) {
         }
         catch ($e) {
             $self->task->clear_handle;
@@ -76,11 +76,11 @@ class Thread::Task::Handle {
         return [
             $self->hid,
             $self->task->meta->name,
-            $task->as_string,
+            $self->task->as_string,
         ];
     }
 
-    method from_array(Class $class: ArrayRef $array) {
+    method from_array(ClassName $class: ArrayRef $array) {
         my ($hid,$task_class,$task_serialized)=@$array;
         Class::MOP::load_class($task_class);
 
@@ -96,7 +96,7 @@ class Thread::Task::Handle {
           );
     }
 
-    method on_message($method,@args) {
+    method on_message(Str $method, @args) {
         unless ($self->task->can($method)) {
             return;
         }
@@ -118,7 +118,7 @@ class Thread::Task::Handle {
         $self->message('__STOPPED__');
     }
 
-    method on_stopped(Task_T $new_task) {
+    method on_stopped(Task_T $new_task, @args) {
         $self->task->_update($new_task);
 
         try {