class Concurrent::Promises::AbstractEventFuture

def callback_notify_blocked(state, promise, index)
  promise.on_blocker_resolution self, index
end