'Flushing actually applies all the operations in the pool.'

def Flush(self):

    DB.DeleteSubjects(self.delete_subject_requests, token=self.token, sync=False)
    for req in self.delete_attributes_requests:
        (subject, attributes, start, end) = req
        DB.DeleteAttributes(subject, attributes, start=start, end=end, token=self.token, sync=False)
    for req in self.set_requests:
        (subject, values, timestamp, replace, to_delete) = req
        DB.MultiSet(subject, values, timestamp=timestamp, replace=replace, to_delete=to_delete, token=self.token, sync=False)
    if (self.delete_subject_requests or self.delete_attributes_requests or self.set_requests):
        DB.Flush()
    for (queue, notifications) in self.new_notifications:
        DB.CreateNotifications(queue, notifications, token=self.token)
    self.new_notifications = []
    self.delete_subject_requests = []
    self.set_requests = []
    self.delete_attributes_requests = []
