func (s *Services) GetAddedServicesForType(serviceType string) chan *Service {
	s.mu.Lock()
	defer s.mu.Unlock()

	added := make(chan *Service)
	s.addedPerType[serviceType] = append(s.addedPerType[serviceType], added)

	return added
}
// GetAddedServicesForType returns a stream of new services for a given type.
GetAddedServicesForType returns a stream of new services for a given type.
// GetAddedServicesForType returns a stream of new services for a given type .
func (s *Services) GetAddedServicesForType(serviceType string) chan *Service {
	s.mu.Lock()
	defer s.mu.Unlock()
	added := make(chan *Service)
	s.addedPerType[serviceType] = append(s.addedPerType[serviceType], added)
	return added
}
func ( s * Services ) GetAddedServicesForType ( serviceType string ) chan * Service { s . mu . Lock ( ) defer s . mu . Unlock ( ) added := make ( chan * Service ) s . addedPerType [ serviceType ] = append ( s . addedPerType [ serviceType ] , added ) return added }
GetAddedServicesForType returns a stream of new services for a given type.
GetAddedServicesForType returns a stream of new services for a given type .