class Concurrent::Collection::CopyOnNotifyObserverSet

def duplicate_and_clear_observers
  synchronize do
    observers = @observers.dup
    @observers.clear
    observers
  end
end