deleted some duplicate files

class FnordMetric::InboundDatagram < EventMachine::Connection

  class << self

    attr_accessor :opts

  end

  def self.start(opts)

    self.opts = opts

    EM.open_datagram_socket(*(opts[:inbound_stream] << self << opts))

  end

  def receive_data(event)

    events << event

    push_next_event

  end

  def push_next_event

    return true if events.empty?

    api.event(@events.pop)

    EM.next_tick(&method(:push_next_event))

  end

  def unbind

    api.disconnect

  end

  def api

    @api ||= FnordMetric::API.new(self.class.opts)

  end

  def events

    @events ||= []

  end

end

 No newline at end of file

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