class Concurrent::Promises::Future

def callback_on_rejection(state, args, callback) 

def callback_on_rejection(state, args, callback)
  state.apply args, callback unless state.fulfilled?
end