Function serviceThatStopsOnItsOwnAfterTimeout

services/manager_test.go:286–295

(timeout time.Duration)

}

func serviceThatStopsOnItsOwnAfterTimeout(timeout time.Duration) Service {
	return NewBasicService(nil, func(serviceContext context.Context) error {
		select {
		case <-serviceContext.Done():
			return nil
		case <-time.After(timeout):
			return nil
		}
	}, nil)
}

func serviceThatDoesntDoAnything() Service {
	// but respects StopAsync and stops.