code: def subscribe(self, callback, existing=True):
          
          if callback in self.callbacks:
              return
          self.callbacks.append(callback)
          if not existing:
              return
          for dist in self:
              callback(dist)
docs: Invoke `callback` for all distributions
  
          If `existing=True` (default),
          call on all existing ones, as well.