class Concurrent::Promises::BlockedPromise
def initialize(delayed, blockers_count, future)
def initialize(delayed, blockers_count, future) super(future) @Delayed = delayed @Countdown = AtomicFixnum.new blockers_count end
def initialize(delayed, blockers_count, future) super(future) @Delayed = delayed @Countdown = AtomicFixnum.new blockers_count end