class Framed::Emitters::Base

Public Class Methods

new(client) click to toggle source
# File lib/framed/emitters.rb, line 7
def initialize(client)
  @client = client
end

Public Instance Methods

enqueue(_event) click to toggle source
# File lib/framed/emitters.rb, line 17
def enqueue(_event)
  raise NotImplementedError
end
start() click to toggle source
# File lib/framed/emitters.rb, line 14
def start
end
stop(_drain = false) click to toggle source
# File lib/framed/emitters.rb, line 11
def stop(_drain = false)
end

Private Instance Methods

transmit(events) click to toggle source
# File lib/framed/emitters.rb, line 23
def transmit(events)
  return unless events && events.length > 0

  begin
    @client.track(events)
  rescue StandardError => exc
    Framed.log_error("#transmit failed: #{exc}")
  end
end