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