code: def purge(self):
          
          self.sender.send_QueuePurge(self.name)
          yield from self.synchroniser.wait(spec.QueuePurgeOK)
          self.reader.ready()
docs: Purge all undelivered messages from the queue.
  
          This method is a :ref:`coroutine <coroutine>`.