Contents

module Dcha
  # :nodoc:
  class PacketManager < Hash
    attr_reader :todo

    def initialize
      @todo = Queue.new
    end

    def <<(chunk)
      self[chunk.tag] ||= []
      self[chunk.tag] << chunk
      self[chunk.tag].uniq!

      check(chunk)
    end

    private

    def check(chunk)
      return unless self[chunk.tag].size == chunk.total
      event = Oj.load(self[chunk.tag].sort.map(&:to_s).join)
      @todo << event
      # TODO: Release memory if buffer not completed
      delete(chunk.tag)
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
dcha-0.1.4	lib/dcha/packet_manager.rb
dcha-0.1.3	lib/dcha/packet_manager.rb
dcha-0.1.2	lib/dcha/packet_manager.rb
dcha-0.1.1	lib/dcha/packet_manager.rb
dcha-0.1.0	lib/dcha/packet_manager.rb