'Serves the elements taken from the queue.'

def get(self, start_idx=0):

    if (start_idx > len(self.repository)):
        start_idx = len(self.repository)
    idx = start_idx
    self.indexes.append(idx)
    idxidx = (len(self.indexes) - 1)
    while True:
        if (self.indexes[idxidx] == len(self.repository)):
            msg = None
        else:
            msg = self.repository[self.indexes[idxidx]]
            self.indexes[idxidx] += 1
            self.clean()
        (yield msg)
