Contents

# frozen_string_literal: true

module Jaeger
  module Client
    class AsyncReporter
      class Buffer
        def initialize
          @buffer = []
          @mutex = Mutex.new
        end

        def <<(element)
          @mutex.synchronize do
            @buffer << element
            true
          end
        end

        def retrieve
          @mutex.synchronize do
            elements = @buffer.dup
            @buffer.clear
            elements
          end
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
jaeger-client-0.8.0	lib/jaeger/client/async_reporter/buffer.rb
jaeger-client-0.7.1	lib/jaeger/client/async_reporter/buffer.rb
jaeger-client-0.7.0	lib/jaeger/client/async_reporter/buffer.rb