'Invoke `callback` for all distributions (including existing ones)'

def subscribe(self, callback):

    if (callback in self.callbacks):
        return
    self.callbacks.append(callback)
    for dist in self:
        callback(dist)
