Method: NATS.wait_for_server

Defined in:
lib/nats/client.rb

.wait_for_server(uri, max_wait = 5) ⇒ Object

:nodoc:


386
387
388
389
390
391
392
 
# File 'lib/nats/client.rb', line 386

def wait_for_server(uri, max_wait = 5) # :nodoc:
  start = Time.now
  while (Time.now - start < max_wait) # Wait max_wait seconds max
    break if server_running?(uri)
    sleep(0.1)
  end
end