class Concurrent::Atom
def initialize(value, opts = {})
-
(ArgumentError)
- if the validator is not a `Proc` (when given)
Options Hash:
(**opts)
-
:validator
(Proc
) -- Optional proc used to validate new
Parameters:
-
opts
(Hash
) -- The options used to configure the atom -
value
(Object
) -- The initial value
def initialize(value, opts = {}) super() @Validator = opts.fetch(:validator, -> v { true }) self.observers = Collection::CopyOnNotifyObserverSet.new self.value = value end