Module: Enumerable

Defined in:
lib/enumerable/async.rb

Overview

Extension to Ruby's Enumerable module that adds asynchronous capabilities.

Instance Method Summary collapse

Instance Method Details

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

Returns an AsyncEnumerator wrapper that provides asynchronous versions of Enumerable methods for parallel execution.

This method enables concurrent processing of Enumerable operations using the socketry/async library, allowing for significant performance improvements when dealing with I/O-bound operations or large collections.

Examples:

Basic usage with async map

[1, 2, 3].async.map { |n| n * 2 }  # => [2, 4, 6] (executed in parallel)

Using with I/O operations

urls.async.map { |url| fetch_data(url) }  # Fetches all URLs concurrently

With custom fiber limit

huge_dataset.async(max_fibers: 100).map { |item| process(item) }
# Processes with max 100 concurrent fibers

Chaining async operations

data.async
    .select { |item| item.valid? }
    .map { |item| process(item) }
    .to_a

Parameters:

  • kwargs (Hash) —

    Configuration options (max_fibers, etc.)

Returns:

  • (Async::Enumerator) —

    An async wrapper around this enumerable that provides parallel execution capabilities for enumerable methods

See Also:



35
36
37
 
# File 'lib/enumerable/async.rb', line 35

def async(**kwargs)
  Async::Enumerator.new(self, **kwargs)
end