code: func (db *DB) triggerPullSubscriptions(bin uint8) {
  	db.pullTriggersMu.RLock()
  	triggers, ok := db.pullTriggers[bin]
  	db.pullTriggersMu.RUnlock()
  	if !ok {
  		return
  	}
  
  	for _, t := range triggers {
  		select {
  		case t <- struct{}{}:
  		default:
  		}
  	}
  }
docs: // triggerPullSubscriptions is used internally for starting iterations
  // on Pull subscriptions for a particular bin. When new item with address
  // that is in particular bin for DB's baseKey is added to pull index
  // this function should be called.