Contents

require 'concurrent'
module Direct
  class Group
    def initialize
      @map = Concurrent::Map.new{|collection, key|
        collection.put(key, Concurrent::Array.new)
      }
    end

    attr_reader :map
    private :map

    def store(key, callable=nil, &block)
      map[key] << (callable || block)
      self
    end

    def fetch(key)
      map.fetch(key)
    end

    def key?(key)
      map.key?(key)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
direct-1.1.0	lib/direct/group.rb