async/await フローを短絡する方法はありますか? 質問する

以下は2016年の古いコンテンツです。ドラゴンに注意してください

これについてはちょうど講演したばかりですが、これは素晴らしいトピックですが、残念ながら、私が提案するソリューションはゲートウェイソリューションであるため、皆さんはあまり気に入らないかもしれません。

仕様があなたにもたらすもの

キャンセルを「正しく」行うことは、実は非常に困難です。人々はしばらくの間、まさにそのことに取り組んできましたが、その上で非同期関数をブロックしないことが決定されました。

ECMAScript コアでこの問題を解決しようとする提案が 2 つあります。

• キャンセルトークン- この問題を解決することを目的としたキャンセル トークンを追加します。
• キャンセル可能な約束-この問題に対処することを目的としたcatch cancel (e) { 構文と構文を追加します。throw.cancel

両方の提案は大幅に変更された先週したがって、私は、どちらも今後 1 年程度で実現するとは期待していません。これらの提案は、ある程度相補的であり、対立するものではありません。

これを解決するためにあなた側でできること

キャンセルトークンは簡単に実装できます。残念ながら、本当に欲しい（別名「第三の状態非同期関数でキャンセル (キャンセルが例外ではない場合) を実行することは、実行方法を制御できないため、現時点では不可能です。次の 2 つの方法があります。

• 代わりにコルーチンを使用してください -青い鳥ジェネレーターとプロミスを使用したサウンドキャンセル機能が搭載されており、使用できます。
• 中止セマンティクスを持つトークンを実装する - これは実際には非常に簡単なので、ここでやってみましょう

キャンセルトークン

さて、トークンはキャンセルを通知します。

class Token {
   constructor(fn) {
      this.isCancellationRequested = false; 
      this.onCancelled = []; // actions to execute when cancelled
      this.onCancelled.push(() => this.isCancellationRequested = true);
      // expose a promise to the outside
      this.promise = new Promise(resolve => this.onCancelled.push(resolve));
      // let the user add handlers
      fn(f => this.onCancelled.push(f));
   }
   cancel() { this.onCancelled.forEach(x => x); }
}

async function update(token) {
   if(token.isCancellationRequested) return;
   var urls = await getCdnUrls();
   if(token.isCancellationRequested) return;
   var metadata = await fetchMetaData(urls);
   if(token.isCancellationRequested) return;
   var content = await fetchContent(metadata);
   if(token.isCancellationRequested) return;
   await render(content);
   return;
}

var token = new Token(); // don't ned any special handling here
update(token);
// ...
if(updateNotNeeded) token.cancel(); // will abort asynchronous actions

async function update(token) {
   var urls = await getCdnUrls(token);
   var metadata = await fetchMetaData(urls, token);
   var content = await fetchContent(metadata, token);
   await render(content, token);
   return;
}

function getCdnUrl(url, token) {
    var xhr = new XMLHttpRequest();
    xhr.open("GET", url);
    var p = new Promise((resolve, reject) => {
      xhr.onload = () => resolve(xhr);
      xhr.onerror = e => reject(new Error(e));
      token.promise.then(x => { 
        try { xhr.abort(); } catch(e) {}; // ignore abort errors
        reject(new Error("cancelled"));
      });
   });
   xhr.send();
   return p;
}