1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
require 'dry/container/item/factory'
module Dry
class Container
# Default registry for registering items with the container
#
# @api public
class Registry
# @private
def initialize
@_mutex = ::Mutex.new
end
# Register an item with the container to be resolved later
#
# @param [Concurrent::Hash] container
# The container
# @param [Mixed] key
# The key to register the container item with (used to resolve)
# @param [Mixed] item
# The item to register with the container
# @param [Hash] options
# @option options [Symbol] :call
# Whether the item should be called when resolved
#
# @raise [Dry::Container::Error]
# If an item is already registered with the given key
#
# @return [Mixed]
#
# @api public
def call(container, key, item, options)
key = key.to_s.dup.freeze
@_mutex.synchronize do
if container.key?(key)
raise Error, "There is already an item registered with the key #{key.inspect}"
end
container[key] = factory.call(item, options)
end
end
def factory
@factory ||= ::Dry::Container::Item::Factory.new
end
end
end
end
|
