Sha256: a4cf3fea8a42df712a427cdd5151a117e030d1e464f89212212686ef66b1a8ca

Contents?: true

Size: 531 Bytes

Versions: 31

Compression:

Stored size: 531 Bytes

Contents

# Copyright (c) 2015 Sqreen. All Rights Reserved.
# Please refer to our terms for more information: https://www.sqreen.io/terms.html
module Sqreen
  # A simple size limited queue.
  # When trying to enqueue more than the capacity
  # the older elements will get thrown
  class CappedQueue < Queue
    attr_reader :capacity

    def initialize(capacity)
      @capacity = capacity
      super()
    end

    alias original_push push

    def push(value)
      pop until size < @capacity
      original_push(value)
    end
  end
end

Version data entries

31 entries across 31 versions & 2 rubygems

Version Path
sqreen-1.15.1 lib/sqreen/capped_queue.rb
sqreen-1.15.0-java lib/sqreen/capped_queue.rb
sqreen-1.15.0 lib/sqreen/capped_queue.rb
sqreen-1.14.2-java lib/sqreen/capped_queue.rb
sqreen-1.14.2 lib/sqreen/capped_queue.rb
sqreen-1.14.1-java lib/sqreen/capped_queue.rb
sqreen-1.14.1 lib/sqreen/capped_queue.rb
sqreen-1.14.0-java lib/sqreen/capped_queue.rb
sqreen-1.14.0 lib/sqreen/capped_queue.rb
sqreen-1.14.0.beta3-java lib/sqreen/capped_queue.rb
sqreen-1.14.0.beta3 lib/sqreen/capped_queue.rb
sqreen-1.14.0.beta2 lib/sqreen/capped_queue.rb
sqreen-1.14.0.beta1 lib/sqreen/capped_queue.rb
sqreen-1.13.4-java lib/sqreen/capped_queue.rb
sqreen-alt-1.13.4 lib/sqreen/capped_queue.rb
sqreen-1.13.4 lib/sqreen/capped_queue.rb
sqreen-1.13.2-java lib/sqreen/capped_queue.rb
sqreen-alt-1.13.2 lib/sqreen/capped_queue.rb
sqreen-1.13.2 lib/sqreen/capped_queue.rb
sqreen-1.13.1-java lib/sqreen/capped_queue.rb