class Concurrent::Collection::CopyOnWriteObserverSet

def observers=(new_set)

def observers=(new_set)
  synchronize { @observers = new_set }
end