code: func HandleScheduleNextQueueItem(db sqlx.Ext, mg storage.MulticastGroup) error {
  	ctx := multicastContext{
  		DB:             db,
  		MulticastGroup: mg,
  	}
  
  	for _, t := range multicastTasks {
  		if err := t(&ctx); err != nil {
  			if err == errAbort {
  				return nil
  			}
  			return err
  		}
  	}
  
  	return nil
  }
docs: // HandleScheduleNextQueueItem handles the scheduling of the next queue-item
  // for the given multicast-group.