@private
# File lib/rspec/mocks/space.rb, line 54 def initialize @proxies = {} @any_instance_recorders = {} @constant_mutators = [] @expectation_ordering = OrderGroup.new @proxy_mutex = new_mutex @any_instance_mutex = new_mutex end
# File lib/rspec/mocks/space.rb, line 97 def any_instance_proxy_for(klass) AnyInstance::Proxy.new(any_instance_recorder_for(klass), proxies_of(klass)) end
# File lib/rspec/mocks/space.rb, line 87 def any_instance_recorder_for(klass, only_return_existing = false) any_instance_mutex.synchronize do id = klass.__id__ any_instance_recorders.fetch(id) do return nil if only_return_existing any_instance_recorder_not_found_for(id, klass) end end end
# File lib/rspec/mocks/space.rb, line 118 def any_instance_recorders_from_ancestry_of(object) # Optimization: `any_instance` is a feature we generally # recommend not using, so we can often early exit here # without doing an O(N) linear search over the number of # ancestors in the object's class hierarchy. return [] if any_instance_recorders.empty? # We access the ancestors through the singleton class, to avoid calling # `class` in case `class` has been stubbed. (class << object; ancestors; end).map do |klass| any_instance_recorders[klass.__id__] end.compact end
# File lib/rspec/mocks/space.rb, line 83 def constant_mutator_for(name) @constant_mutators.find { |m| m.full_constant_name == name } end
# File lib/rspec/mocks/space.rb, line 63 def new_scope NestedSpace.new(self) end
# File lib/rspec/mocks/space.rb, line 101 def proxies_of(klass) proxies.values.select { |proxy| klass === proxy.object } end
# File lib/rspec/mocks/space.rb, line 105 def proxy_for(object) proxy_mutex.synchronize do id = id_for(object) proxies.fetch(id) { proxy_not_found_for(id, object) } end end
# File lib/rspec/mocks/space.rb, line 79 def register_constant_mutator(mutator) @constant_mutators << mutator end
# File lib/rspec/mocks/space.rb, line 114 def registered?(object) proxies.has_key?(id_for object) end
# File lib/rspec/mocks/space.rb, line 72 def reset_all proxies.each_value { |proxy| proxy.reset } @constant_mutators.reverse.each { |mut| mut.idempotently_reset } any_instance_recorders.each_value { |recorder| recorder.stop_all_observation! } any_instance_recorders.clear end
# File lib/rspec/mocks/space.rb, line 67 def verify_all proxies.each_value { |proxy| proxy.verify } any_instance_recorders.each_value { |recorder| recorder.verify } end
# File lib/rspec/mocks/space.rb, line 167 def any_instance_recorder_not_found_for(id, klass) any_instance_recorders[id] = AnyInstance::Recorder.new(klass) end
# File lib/rspec/mocks/space.rb, line 174 def id_for(object) id = object.__id__ return id if object.equal?(::ObjectSpace._id2ref(id)) # this suggests that object.__id__ is proxying through to some wrapped object object.instance_exec do @__id_for_rspec_mocks_space ||= ::SecureRandom.uuid end end
We don't want to depend on the stdlib ourselves, but if the user is using threads then a Mutex will be available to us. If not, we don't need to synchronize anyway.
# File lib/rspec/mocks/space.rb, line 137 def new_mutex defined?(::Mutex) ? ::Mutex.new : FakeMutex end
# File lib/rspec/mocks/space.rb, line 148 def proxy_not_found_for(id, object) proxies[id] = case object when NilClass then ProxyForNil.new(@expectation_ordering) when TestDouble then object.__build_mock_proxy(@expectation_ordering) when Class if RSpec::Mocks.configuration.verify_partial_doubles? VerifyingPartialClassDoubleProxy.new(self, object, @expectation_ordering) else PartialClassDoubleProxy.new(self, object, @expectation_ordering) end else if RSpec::Mocks.configuration.verify_partial_doubles? VerifyingPartialDoubleProxy.new(object, @expectation_ordering) else PartialDoubleProxy.new(object, @expectation_ordering) end end end