Class: GitMulticast::Task::Runner

Inherits:

Object

• Object
• GitMulticast::Task::Runner

Defined in:

lib/git_multicast/task/runner.rb

Instance Method Summary

• #initialize(tasks, pool: Pool.pool) ⇒ Runner constructor

  A new instance of Runner.

• #run! ⇒ Object

Constructor Details

#initialize(tasks, pool: Pool.pool) ⇒ Runner

Returns a new instance of Runner.

# File 'lib/git_multicast/task/runner.rb', line 4

def initialize(tasks, pool: Pool.pool)
  @tasks = tasks
  @pool = pool
  @result_queue = Queue.new
end

Instance Method Details

#run! ⇒ Object

# File 'lib/git_multicast/task/runner.rb', line 10

def run!
  tasks
    .map(&wrap_with_notify)
    .map(&schedule)
    .map(&await)
end