Class: SwapiDev::AsyncStream

Inherits:

Object

• Object
• SwapiDev::AsyncStream

Defined in:

lib/swapi_dev/client/async_stream.rb

Instance Method Summary

• #initialize(enumerable) ⇒ AsyncStream constructor

  A new instance of AsyncStream.

• #map ⇒ Object
• #sum(&block) ⇒ Object

Constructor Details

#initialize(enumerable) ⇒ AsyncStream

Returns a new instance of AsyncStream.

# File 'lib/swapi_dev/client/async_stream.rb', line 5

def initialize(enumerable)
  @enumerable = enumerable
end

Instance Method Details

#map ⇒ Object

# File 'lib/swapi_dev/client/async_stream.rb', line 9

def map
  enumerable.map do |item|
    Thread.new { yield(item) }
  end.map(&:value)
end

#sum(&block) ⇒ Object

# File 'lib/swapi_dev/client/async_stream.rb', line 15

def sum(&block)
  map(&block).inject(:+)
end