Method: Zipkin::AsyncReporter.create

Defined in:
lib/zipkin/async_reporter.rb

.create(sender:, flush_interval:) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/zipkin/async_reporter.rb', line 9

def self.create(sender:, flush_interval:)
  reporter = new(sender)

  # start flush thread
  Thread.new do
    loop do
      reporter.flush
      sleep(flush_interval)
    end
  end

  reporter
end