Class: Rubcask::Worker::DirectWorker

Inherits:

Object

• Object
• Rubcask::Worker::DirectWorker

Defined in:

lib/rubcask/worker/direct_worker.rb

Overview

Worker implementation that executes the job in the current thread

Instance Method Summary

• #close ⇒ Object
• #initialize ⇒ DirectWorker constructor

  A new instance of DirectWorker.

• #push(task) ⇒ Object

Constructor Details

#initialize ⇒ DirectWorker

Returns a new instance of DirectWorker.

# File 'lib/rubcask/worker/direct_worker.rb', line 9

def initialize
  @logger = Logger.new($stdout)
end

Instance Method Details

#close ⇒ Object

# File 'lib/rubcask/worker/direct_worker.rb', line 19

def close
end

#push(task) ⇒ Object

# File 'lib/rubcask/worker/direct_worker.rb', line 13

def push(task)
  task.call
rescue => e
  @logger.warn("Error while executing task #{e}")
end