wait_for_successful_connection

in lib/logstash/outputs/opensearch.rb [276:290]

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

  def wait_for_successful_connection
    after_successful_connection_done = @after_successful_connection_done
    return unless after_successful_connection_done
    stoppable_sleep 1 until after_successful_connection_done.true?

    status = @after_successful_connection_thread && @after_successful_connection_thread.value
    if status.is_a?(Exception) 
      
      @logger.error "OpenSearch setup did not complete normally, please review previously logged errors",
                    message: status.message, exception: status.class
    else
      @after_successful_connection_done = nil 
    end
  end