Contents

require 'concurrent'

module Vizsla
  class Storage
    attr_reader :values

    def initialize
      @values = Concurrent::Array.new
    end

    def add(payload)
      @values << payload
    end
    alias_method :<<, :add

    def add_payload(payload)
      @values += payload if payload.is_a?(Array)
    end

    def unload
      duplicate_values = @values.dup
      @values.clear
      duplicate_values
    end

    def unloaded?
      @values.empty?
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
tracebin-0.0.7	lib/vizsla/storage.rb