Module: Enumerable

Defined in:
lib/async_enum.rb

Instance Method Summary collapse

Instance Method Details

#async(pool_size = nil) ⇒ Object 



4
5
6
7
 
# File 'lib/async_enum.rb', line 4

def async(pool_size = nil)
  enum = self.is_a?(Enumerator) ? self : self.each
  Enumerator::Async.new(enum, pool_size)
end