Function WaitAllStartedC

rivershared/startstop/start_stop.go:333–344

WaitAllStartedC waits until all the given services are started (or stopped in a degenerate start scenario, like if context is cancelled while starting up). This variant returns a channel so that a caller can apply a timeout branch with `select` if they'd like. For the most part this shouldn't be ne

(services ...Service)

// because the services themselves have already background themselves, and we
// have to wait until the slowest service has started anyway.
func WaitAllStartedC(services ...Service) <-chan struct{} {
	allStarted := make(chan struct{})

	go func() {
		defer close(allStarted)
		for _, service := range services {
			<-service.Started()
		}
	}()

	return allStarted
}