code: func (m *SubscriptionManager) notifySubscribers(ntfn BlockNtfn) {
  	log.Tracef("Notifying %v", ntfn)
  
  	for _, subscriber := range m.subscribers {
  		m.notifySubscriber(subscriber, ntfn)
  	}
  }
docs: // notifySubscribers notifies all currently active subscribers about the block.