可以与抓取轮询异步，直到满足条件？ 幸存拒绝

如何解决可以与抓取轮询异步，直到满足条件？ 幸存拒绝

使用提取API和异步/等待，是否可以无限期地继续轮询，而不管URL是否可用？我预计URL最终可能会变得可用，因此我想继续尝试直到满足条件。试图提供最小可行的代码示例，但我不确定我是否将其剥离：

// this is just a placeholder. It will eventually be a function 
// that evaluates something real. 
// Assume validContinue gets updated elsewhere.      
function shouldContinue() {
    return validContinue;
}
      
async function wonderPoll(someUrl) {

  // just a delay mechanism
  function wait(ms = 1000) {
    return new Promise(resolve => {
      setTimeout(resolve,ms);
    });
  }

  // the actual individual poll
  async function pollingFunction(url) {

    const response = await fetch(url,{
      cache: 'no-store'
    });

    if (response.ok) {
      return response;
    } else {
      Promise.reject(response);
    }

  }

  // allegedly keep polling until condition is met. 
  // But the rejected Promise is breaking out!
  while (shouldContinue()) {
    await wait();
    result = await pollingFunction(someUrl);
  }
  
  // when the fetch hits a rejected state,we never get here!
  console.log('done with the while loop,returning last successful result')

  return result;
}

const sampleUrl = 'https://get.geojs.io/v1/ip/country.json?ip=8.8.8.8';
const sampleUrl2 = 'http://totallybroken_fo_sho';

// swap the URL to test
wonderPoll(sampleUrl)
  .then((result) => {
    console.log('got a result',result)
  })
  .catch((err) => {
    console.log('got an error',err)
  });

我知道发生了什么事（我认为）。父调用最终执行轮询功能，该功能在Promise上拒绝。理论上仍然满足继续的条件，但是拒绝会从While循环中跳出并直接向上发送到拒绝。这一直传播到原始/初始Promise的catch方法。对于已解决的Promises，它甚至不会触及While循环之后的任何代码。

我不知道如何防止这种情况的发生。我想我不理解拦截和解决诺言的语法。当我将响应解析器中的Promise.reject替换为Promise.resolve(response)时，它仍然最终拒绝了顶部。

如果我提供的URL有效，它将持续到不再满足条件为止。

---

这是一个小提琴：https://jsfiddle.net/gregpettit/qf495bjm/5/

要使用小提琴，“停止”按钮将模拟满足的条件，并且我提供了两个必须手动交换（通过传递someUrl或someUrl2）进行测试的URL。

预期结果：

• 具有良好的URL，连续轮询（必须在开发工具中深入网络），直到满足条件为止（按Stop！），然后调用函数的“ then”即可显示结果。
• URL错误，持续轮询直到满足条件，然后调用函数的“ catch”显示错误

实际结果：

• 积极的测试用例就可以了
• 阴性测试用例直接解决了问题

解决方法

您可以try…catch以防止其跳出循环。

while (shouldContinue()) {
  try {
    await wait();
    result = await pollingFunction(someUrl);
  } catch (e) {}
}

,

在while循环中更改代码以尝试/捕获，以便您可以捕获错误

没有错误或错误的原因时，结果可以保存一个值

一旦循环停止，您要么返回值，要么抛出原因

如下

async function wonderPoll(someUrl) {

  // just a delay mechanism
  function wait(ms = 1000) {
    return new Promise(resolve => {
      setTimeout(resolve,ms);
    });
  }

  // the actual individual poll
  async function pollingFunction(url) {

    const response = await fetch(url,{
      cache: 'no-store'
    });

    if (response.ok) {
      return response;
    } else {
      Promise.reject(response);
    }

  }

  // allegedly keep polling until condition is met. But the rejected Promise is breaking out!
  while (shouldContinue()) {
    try {
      await wait();
      const value = await pollingFunction(someUrl);
      result = {value};
    } catch (reason) {
      result = {reason};
    }
  }
  // when the fetch hits a rejected state,we never get here!
  console.log('done with the while loop,returning last successful result')
  if (result.reason) {
    throw result.reason;
  }
  return result.value;
}

运行示例https://jsfiddle.net/twkbo9pg/

该示例在结果中包含status，但这是不必要的（我从我的Promise.allSettled polyfill借来了代码，却忘记了删除该属性）

,

您可能想查看可观察的流！如果随着时间的推移会有大量数据传入，那么这就是rxjs的全部内容。

实际上，有几种方法可以解决此问题，只要感觉有点简陋（有点哈哈）。

import { ajax } from "rxjs/ajax";
import { duration } from "moment-timezone"; // I copied this from some old code... whatever.
import { catchError,map,share,switchMap } from "rxjs/operators";

const baseUrl = "http://foo.bar"
const base = (method,headers = {}) => ({
  method,headers: {
    Accept: "application/json",...headers,},crossDomain: true,withCredentials: true,})

const ajaxGet = url => ajax({ ...base("GET"),url })

export const userEpic = timer(0,duration(5,"minutes").asMilliseconds()).pipe(
  switchMap(() =>
    ajaxGet(`${baseUrl}/users`).pipe(
      map(({ response }) => getUsersSuccess(response)),catchError(e => of(getUsersError(e))),)
  ),share()
)

,

两件事

 } else {
            Promise.reject(response);
        }

应该返回。现在它正在“偶然地”工作。

 } else {
            return Promise.reject(response);
        }

第二，result = await pollingFunction(someUrl);可能要向其添加.catch： result = await pollingFunction(someUrl).catch(_=>null);或可以在随附的while

中进行测试的任何内容

但是我认为您可以这样简化整个过程：

export async function wonderPoll(someUrl) {
    while (shouldContinue()) {
        await wait();

        const response = await fetch(someUrl,{ cache: 'no-store' });

        if (response.ok)
            return response;
    }
    return Promise.reject(); // only if !shouldContinue()
}