Method RemoveAndWaitChan

lib/model/service_map.go:115–119

RemoveAndWaitChan removes the service at the given key, stopping it on the supervisor. The returned channel will produce precisely one error value: either the return value from RemoveAndWait (possibly nil), or errSvcNotFound if the service was not found.

(k K, timeout time.Duration)

// value: either the return value from RemoveAndWait (possibly nil), or
// errSvcNotFound if the service was not found.
func (s *serviceMap[K, S]) RemoveAndWaitChan(k K, timeout time.Duration) <-chan error {
	ret := s.StopAndWaitChan(k, timeout)
	delete(s.services, k)
	return ret
}

// Each calls the given function for each service in the map. An error from
// fn will stop the iteration and be returned as-is.