class EventMachine::Completion

def execute_state_callbacks(state)

Iterate all callbacks for a given state, and remove then call them. 
def execute_state_callbacks(state)
  while callback = @callbacks[state].shift
    callback.call(*value)
  end
end