Sha256: 26b69293419319ab30e2b86db9b0f4ba746f18ca99ccd979883f70acf3795081
Contents?: true
Size: 516 Bytes
Versions: 7
Compression:
Stored size: 516 Bytes
Contents
# frozen_string_literal: true module Jaeger module Reporters class RemoteReporter 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
7 entries across 7 versions & 3 rubygems