Sha256: 5c5bbce523b6ea8a2528f1dfc6385ee689f8bd3b07ad0fffce1aaf64fca3c72d
Contents?: true
Size: 1007 Bytes
Versions: 4
Compression:
Stored size: 1007 Bytes
Contents
class FnordMetric::InboundStream < EventMachine::Connection @@opts = nil def self.start(opts) @@opts = opts EM.start_server(*opts[:inbound_stream], self) end def self.options(opts) @@opts = opts end def receive_data(chunk) @buffer << chunk next_event end def next_event read_next_event push_next_event end def read_next_event while (event = @buffer.slice!(/^(.*)\n/)) @events_buffered += 1 @events << event end end def push_next_event return true if @events.empty? @events_buffered -= 1 @api.event(@events.pop) close_connection? EM.next_tick(&method(:push_next_event)) end def close_connection? @api.disconnect unless @streaming || (@events_buffered!=0) end def post_init @api = FnordMetric::API.new(@@opts) @events_buffered = 0 @streaming = true @buffer = "" @events = [] end def unbind @streaming = false close_connection? end end
Version data entries
4 entries across 4 versions & 1 rubygems