0

我想使用 ember-concurrency 来处理地址集合的批量验证。地址验证由第三方 API 完成，该 API 调用服务器端函数，然后在服务器完成其工作时“回调”到客户端。

这似乎是一个使用 ember-concurrency 附加组件的地方，但我不知道如何正确使用它。我认为挑战在于对服务器的 api 调用在服务器端进程启动后立即返回。如何让 ember-concurrency 知道对服务器的调用和回调函数之间的连接，以便“任务”等待回调完成作为任务已完成的标志？我现在让代码工作的方式，“结果”（可以理解）总是空的。

import Component from '@glimmer/component';
import { inject as service } from '@ember/service';
import { task } from 'ember-concurrency';

export default class BatchAddressInputComponent extends Component {
    @service api;
    addressList = "";

    //addressList populated from a TextArea
    @task *DoAddressValidation ()
    {
        let results = yield this.api.BatchQueryAddresses(this.addressList);
        alert(results); //not surprisingly, 'results' is always null
    }
}
    
    
import Service from '@ember/service';

export default class ApiService extends Service {
  _api;

  //API *should* be available as a global object, imported as a <script> on
  // application start-up.
  constructor() {
    super(...arguments);
    this._api = API;
  }

  BatchQueryAddresses(addressList) {
    this._api.BatchQueryAddress(addressList, 2, this._queryAddressCallback, null, 2000);
  }

  _queryAddressCallback(result, error) {
    if (error) {
        alert("Error: " + result);
        return;
    }
    var j = JSON.stringify(result, null, ' ');
    return(j);
  }
}
4

1 回答 1

1

您需要返回一个Promise. 构造new Promise(...)函数正是为此而生的：

BatchQueryAddresses(addressList) {
  return new Promise((resolve, reject) => {
    this._api.BatchQueryAddress(
      addressList,
      2,
      (result, error) => {
        if (error) {
          reject("Error: " + result);
        } else {
          const j = JSON.stringify(result, null, ' ');
          resolve(j);
        }
      },
      null,
      2000
    );
  });
}
于 2021-10-09T17:38:04.217 回答