code: def flush(self):
          
          if self.buffer is None:
              return
          data = self.buffer
          self.buffer = []
          for x in self.dests:
              yield from x.enqueue_task(self, *data)
docs: Flush the buffer of buffered tiers to our destination tiers.