How to use CAF with Axios' `cancelToken` argument? about caf

[aguynamedben]

Also, thanks again for providing this library, it helped us solve a hard problem.

In other parts of our app we're now playing with similar ideas around wrapping Promises as special-case Observables that return a single value. Async world is crazy!

[aguynamedben]

I think this is doing the trick, I'm not sure if there's a more direct way to just pass something to Axios' cancelToken, though.

The idea is:

• Listen for CAF to tell us about cancelation
• Forward the cancelation to Axios in the way that Axios documents

  static sync = CAF(function *sync(signal, syncRequest) {
    // Axios cancellation
    const CancelToken = axios.CancelToken;
    const source = CancelToken.source();
    signal.pr.catch((reason) => {
      log.warn(`canceling any outstanding axios requests, reason: ${reason}`);
      source.cancel();
    });

    const response1 = yield axios.get(`/members/${id}`, {
      params: {
        foo: 'bar',
      },
      cancelToken: source.token,
    });

    const response2 = yield axios.get(`/members/${id}`, {
      params: {
        baz: 'bang',
      },
      cancelToken: source.token,
    });

[getify]

Perhaps try:

yield axios.get(.. , {
   // ..
   cancelToken: new axios.CancelToken(cancel => signal.pr.catch(cancel))
})

[getify]

Closing for now, hopefully that suggestion worked.

[aguynamedben]

Hey, thank you for the reply, and sorry for the delay in reporting back. Here's what I'm doing now, but I will try your method when I get a chance.

    // Forward CAF cancellation to Axios so we can abort a sync mid-request. We
    // don't need to do this in every DataSource, it's an optimization, but
    // maybe there's a way we can generalize it in the main DataSource class one
    // day.
    // https://github.com/getify/CAF/issues/16#issuecomment-640120307
    const CancelToken = axios.CancelToken;
    const source = CancelToken.source();
    signal.pr.catch((reason) => {
      log.debug(`canceling any outstanding axios requests, reason: ${reason}`);
      source.cancel();
    });

    // Get boards ids for member and orgs - /members/{id}
    log.debug(`getting board - /members/${account.upstreamId}`);
    const boardsResponse = yield client.get(`/members/${account.upstreamId}`, {
      params: {
        fields: 'idBoards',
        organizations: 'all',
        organization_fields: 'idBoards',
      },
      cancelToken: source.token,
    });