Contents

module Errplane
  class MaxQueue < Queue
    attr_accessor :max_depth

    def initialize(max_depth = 10_000)
      @max_depth = max_depth
      super()
    end

    def push_or_discard(data)
      push(data) if size < @max_depth
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
errplane-0.5.10	lib/errplane/max_queue.rb
errplane-0.5.9	lib/errplane/max_queue.rb
errplane-0.5.8	lib/errplane/max_queue.rb
errplane-0.5.7	lib/errplane/max_queue.rb