Change to Timeout::Error as signal

mbj · Mar 8, 2024 · d8a78d1 · d8a78d1
1 parent bece63b
commit d8a78d1
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/lib/mutant/parallel/connection.rb b/lib/mutant/parallel/connection.rb
@@ -81,7 +81,7 @@ def read_till_final
       private
 
         def timeout
-          @errors << Timeout
+          @errors << Timeout::Error
         end
 
         def advance_result

diff --git a/spec/integration/mutant/parallel_spec.rb b/spec/integration/mutant/parallel_spec.rb
@@ -245,7 +245,7 @@ def status
     expect(sink.status).to eql(
       [
         Mutant::Parallel::Response.new(
-          error:  Timeout,
+          error:  Timeout::Error,
           job:    Mutant::Parallel::Source::Job.new(index: 0, payload: 1),
           log:    '',
           result: nil

diff --git a/spec/unit/mutant/parallel/connection/reader_spec.rb b/spec/unit/mutant/parallel/connection/reader_spec.rb
@@ -191,7 +191,7 @@ def marshal_load
         verify_events do
           expect(apply).to eql(
             Mutant::Parallel::Response.new(
-              error:  Timeout,
+              error:  Timeout::Error,
               job:    job,
               log:    '<log>',
               result: nil
@@ -241,7 +241,7 @@ def marshal_load
         verify_events do
           expect(apply).to eql(
             Mutant::Parallel::Response.new(
-              error:  Timeout,
+              error:  Timeout::Error,
               job:    job,
               log:    '',
               result: nil
@@ -262,7 +262,7 @@ def marshal_load
         verify_events do
           expect(apply).to eql(
             Mutant::Parallel::Response.new(
-              error:  Timeout,
+              error:  Timeout::Error,
               job:    job,
               log:    '',
               result: nil

diff --git a/spec/unit/mutant/parallel/worker_spec.rb b/spec/unit/mutant/parallel/worker_spec.rb
@@ -317,7 +317,7 @@ def new_deadline
     context 'when processing jobs till error' do
       let(:response_a) do
         Mutant::Parallel::Response.new(
-          error:  Timeout,
+          error:  Timeout::Error,
           job:    0,
           log:    'log',
           result: nil