class Protobuf::Rpc::Connectors::EventMachine

def resume_fiber(fib)
  ::EM::cancel_timer(@timeout_timer)
  fib.resume(true)
rescue => ex
  log_exception(ex)
  message = "Synchronous client failed: #{ex.message}"
  error_stop_reactor(message)
end