class Protobuf::Rpc::Connectors::EventMachine

def set_timeout_and_validate_fiber
  @timeout_timer = ::EM::add_timer(@options[:timeout]) do
    message = "Client timeout of #{@options[:timeout]} seconds expired"
    error_stop_reactor(message)
  end
  Fiber.yield
rescue FiberError => ex
  log_exception(ex)
  message = "Synchronous calls must be in 'EM.fiber_run' block"
  error_stop_reactor(message)
end