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

	removed := make(chan *Service)
	s.removedPerType[serviceType] = append(s.removedPerType[serviceType], removed)

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