lib/protobuf/nats.rb in protobuf-nats-0.2.0 vs lib/protobuf/nats.rb in protobuf-nats-0.2.1

@@ -48,10 +48,11 @@
     end
 
     def self.start_client_nats_connection
       @start_client_nats_connection ||= begin
         GET_CONNECTED_MUTEX.synchronize do
-          return if @start_client_nats_connection
+          break true if @client_nats_connection
+          break true if @start_client_nats_connection
 
           @client_nats_connection = NatsClient.new
           @client_nats_connection.connect(config.connection_options)
 
           # Ensure we have a valid connection to the NATS server.