run

in lib/logstash/outputs/kusto/interval.rb [67:79]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    def run
      @mutex.synchronize do
        loop do
          @sleeper.wait(@mutex, @interval)
          break if @stopped

          @procsy.call
        end
      end
    ensure
      @sleeper.broadcast
    end