after_successful_connection

in lib/logstash/plugin_mixins/opensearch/common.rb [75:85]

• 10 lines of code
• 5 McCabe index (conditional complexity)

    def after_successful_connection(&block)
      Thread.new do
        sleep_interval = @retry_initial_interval
        until successful_connection? || @stopping.true?
          @logger.debug("Waiting for connectivity to OpenSearch cluster, retrying in #{sleep_interval}s")
          sleep_interval = sleep_for_interval(sleep_interval)
        end
        block.call if successful_connection?
      end
    end