class ActiveSupport::Notifications::Fanout

def unsubscribe(subscriber)
  synchronize do
    @subscribers.reject! { |s| s.matches?(subscriber) }
    @listeners_for.clear
  end
end