Class: TestBench::Parallel::Session::TelemetrySink

Inherits:
Object
  • Object
show all
Includes:
Telemetry::Sink
Defined in:
lib/test_bench/parallel/session.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(queue) ⇒ TelemetrySink

Returns a new instance of TelemetrySink.



123
124
125
 
# File 'lib/test_bench/parallel/session.rb', line 123

def initialize(queue)
  @queue = queue
end

Instance Attribute Details

#event_data_batch ⇒ Object 



116
117
118
 
# File 'lib/test_bench/parallel/session.rb', line 116

def event_data_batch
  @event_data_batch ||= []
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



121
122
123
 
# File 'lib/test_bench/parallel/session.rb', line 121

def queue
  @queue
end

Instance Method Details

#flush ⇒ Object 



131
132
133
134
135
 
# File 'lib/test_bench/parallel/session.rb', line 131

def flush
  queue.push(event_data_batch)

  self.event_data_batch = nil
end

#receive(event_data) ⇒ Object 



127
128
129
 
# File 'lib/test_bench/parallel/session.rb', line 127

def receive(event_data)
  event_data_batch.push(event_data)
end