class Concurrent::Promises::BlockedTaskPromise

@abstract

Public Class Methods

new(delayed, blockers_count, default_executor, executor, args, &task) click to toggle source
# File lib/concurrent-ruby/concurrent/promises.rb, line 1707
def initialize(delayed, blockers_count, default_executor, executor, args, &task)
  raise ArgumentError, 'no block given' unless block_given?
  super delayed, 1, Future.new(self, default_executor)
  @Executor = executor
  @Task     = task
  @Args     = args
end

Public Instance Methods

executor() click to toggle source
# File lib/concurrent-ruby/concurrent/promises.rb, line 1715
def executor
  @Executor
end