code: def cancel(self, consumers):
          
          for consumer in consumers:
              del self._consumers[consumer.queue]
              protocol = yield self.when_connected()
              yield protocol.cancel(consumer)
docs: Cancel a consumer that was previously started with consume.
  
          Args:
              consumer (list of fedora_messaging.api.Consumer): The consumers to cancel.