Method: Async::Barrier#async
- Defined in:
- lib/async/barrier.rb
#async(*arguments, parent: (@parent or Task.current), **options, &block) ⇒ Object
Execute a child task and add it to the barrier.
43 44 45 46 47 48 49 |
# File 'lib/async/barrier.rb', line 43 def async(*arguments, parent: (@parent or Task.current), **, &block) task = parent.async(*arguments, **, &block) @tasks.append(TaskNode.new(task)) return task end |