async function run()

in src/k8s/common/streamResults/index.ts [25:46]

• 18 lines of code
• 4 McCabe index (conditional complexity)

  async function run() {
    try {
      const requestParams = new URLSearchParams(urlParams);
      const requestUrl = `${url}?${requestParams.toString()}`;

      const { kind, items, metadata } = await ApiProxy.request(requestUrl);

      if (isCancelled) return;

      add(items, kind);

      const watchParams = new URLSearchParams({
        ...urlParams,
        watch: '1',
        resourceVersion: metadata.resourceVersion,
      });
      const watchUrl = `${url}?${watchParams.toString()}`;
      socket = ApiProxy.stream(watchUrl, update, { isJson: true });
    } catch (err) {
      if (errCb) errCb(err as ApiError, cancel);
    }
  }