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.



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

def initialize(queue)
  @queue = queue
end

Instance Attribute Details

#event_data_batch ⇒ Object 



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

def event_data_batch
  @event_data_batch ||= []
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



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

def queue
  @queue
end

Instance Method Details

#flush ⇒ Object 



136
137
138
139
140
 
# File 'lib/test_bench/parallel/session.rb', line 136

def flush
  queue.push(event_data_batch)

  self.event_data_batch = nil
end

#receive(event_data) ⇒ Object 



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

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