class Concurrent::Collection::CopyOnNotifyObserverSet

def delete_observer(observer)
  synchronize do
    @observers.delete(observer)
    observer
  end
end