Class: Multiki

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/multiki.rb,
lib/multiki/version.rb

Constant Summary collapse

VERSION = 
"1.0.0"

Instance Method Summary collapse

Constructor Details

#initialize(tasks, concurrency: 10) ⇒ Multiki

Returns a new instance of Multiki.



3
4
5
6
7
8
 
# File 'lib/multiki.rb', line 3

def initialize(tasks, concurrency: 10)
  @concurrency = concurrency
  @queue = Queue.new

  self.<< tasks
end

Instance Method Details

#<<(tasks) ⇒ Object 



10
11
12
13
14
 
# File 'lib/multiki.rb', line 10

def <<(tasks)
  [*tasks].each do |task|
    @queue.push task
  end
end

#each(&block) ⇒ Object 



16
17
18
 
# File 'lib/multiki.rb', line 16

def each(&block)
  run(&block)
end