inbound datagram push events to redis api on EM.next_tick

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

  end

  def receive_data(data)

    api.event(data)

  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