Function waitForCompileUpdateNotification

pkg/cli/compile_update_check.go:132–163

(ctx context.Context, results <-chan *compileUpdateNotification, timeout time.Duration)

}

func waitForCompileUpdateNotification(ctx context.Context, results <-chan *compileUpdateNotification, timeout time.Duration) *compileUpdateNotification {
	if results == nil {
		return nil
	}

	if timeout <= 0 {
		select {
		case result, ok := <-results:
			if !ok {
				return nil
			}
			return result
		default:
			return nil
		}
	}

	timer := time.NewTimer(timeout)
	defer timer.Stop()

	select {
	case result, ok := <-results:
		if !ok {
			return nil
		}
		return result
	case <-timer.C:
		return nil
	case <-ctx.Done():
		return nil
	}
}

func runCompileUpdateCheck(ctx context.Context, client *http.Client) (*compileUpdateNotification, error) {
	currentVersion := GetVersion()