class ActiveSupport::Notifications::Fanout

def unsubscribe(subscriber_or_name)
  synchronize do
    case subscriber_or_name
    when String
      @subscribers.reject! { |s| s.matches?(subscriber_or_name) }
    else
      @subscribers.delete(subscriber_or_name)
    end
    @listeners_for.clear
  end
end