Class: Contr::Async::Pool::Base

Inherits:

Object

• Object
• Contr::Async::Pool::Base

Defined in:

lib/contr/async/pool.rb

Direct Known Subclasses

Fixed, GlobalIO

Instance Method Summary

• #create_executor ⇒ Object
• #executor ⇒ Object
• #future(*args, &block) ⇒ Object
• #zip(*futures) ⇒ Object

Instance Method Details

#create_executor ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/contr/async/pool.rb', line 13

def create_executor
  raise NotImplementedError, "pool should implement `#create_executor` method"
end

#executor ⇒ Object

# File 'lib/contr/async/pool.rb', line 9

def executor
  @executor ||= create_executor
end

#future(*args, &block) ⇒ Object

# File 'lib/contr/async/pool.rb', line 17

def future(*args, &block)
  Concurrent::Promises.future_on(executor, *args, &block)
end

#zip(*futures) ⇒ Object

# File 'lib/contr/async/pool.rb', line 21

def zip(*futures)
  Concurrent::Promises.zip_futures_on(executor, *futures)
end