'Args:
ds (DataFlow): input DataFlow
nr (int): number of times to repeat ds.
Set to -1 to repeat ``ds`` infinite times.'

def __init__(self, ds, nr):

    self.nr = nr
    super(RepeatedData, self).__init__(ds)
