code: def on_shutdown(self, broker):
          
          _v and LOG.debug('%r.on_shutdown()', self)
          fire(self, 'shutdown')
          self.on_disconnect(broker)
docs: Called by :meth:`Broker.shutdown` to allow the stream time to
          gracefully shutdown. The base implementation simply called
          :meth:`on_disconnect`.