Module: Async::Await::Enumerable

Defined in:
lib/async/await/enumerable.rb

Instance Method Summary collapse

Instance Method Details

#async_each(parent: Task.current, &block) ⇒ Object 



32
33
34
35
36
37
38
39
40
 
# File 'lib/async/await/enumerable.rb', line 32

def async_each(parent: Task.current, &block)
	self.each do |*args|
		parent.async do
			yield *args
		end
	end
	
	return self
end

#async_map(parent: Task.current, &block) ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/async/await/enumerable.rb', line 24

def async_map(parent: Task.current, &block)
	self.map do |*args|
		parent.async do
			yield *args
		end
	end.map(&:wait)
end