Module: Async::Enumerable::AsyncMethod

Defined in:
lib/async/enumerable.rb

Overview

Async method module - included last to override Enumerable's version.

Instance Method Summary collapse

Instance Method Details

#async(**kwargs) ⇒ Async::Enumerator

Returns async enumerator (idempotent - returns self if already async).

Parameters:

  • kwargs (Hash) —

    Configuration options (max_fibers, etc.)

Returns:



60
61
62
63
64
65
66
 
# File 'lib/async/enumerable.rb', line 60

def async(**kwargs)
  return self if kwargs.empty? && self.class.include?(Async::Enumerable)

  source = __async_enumerable_collection || self
  config = __async_enumerable_config
  Async::Enumerator.new(source, config, **kwargs)
end