約束のあるデータセットを生成

Question

私は現在、javascriptで非同期呼び出しのペアの配列を生成しようとしていますが、正しい順序で取得できないようです。

generateDataPoints: function (iterable, source, arg) { 
    let pairs = [] 
    let prevTime = 0 
    for (let index in iterable) { 
    let event = iterable[index] 
    getTime(event.valueOf()).then(function (time) { 
     query(source[arg], event.valueOf()).then(function(val) { 
     if (time !== prevTime) { 
      prevTime = time 
      pairs.push([time, val]) 
      console.log(pairs) // This works as expected but only happens after the program returns 
     } else { 
      Promise.resolve() 
     } 
     }) 
    }) 
    } 
    return Promise.resolve(pairs) 
} 

問題は、私が戻った後に "pairs.push .."コマンドが発生することです。私は正確に何がうまくいかないのか、どのようにこのプロセスを同期させることができるのか理解できません。どんな助けもありがとうございます。

Answer 1

同期コード（forループなど）と非同期コードを混在させています。

が

function generateDataPoints(iterable, source, arg) { 
    let prevTime = 0 
    [...iterable].reduce((promiseChain, event) => { 
    let pairs; 
    return promiseChain 
     .then(p => { 
     pairs = p; 
     return Promise.all([ 
      getTime(event.valueOf()), 
      query(source[arg], event.valueOf()) 
     ]) 
     }) 
     .then(([time, val]) => { 
     if (time !== prevTime) { 
      prevTime = time 
      return pairs.concat([[time, val]]); 
     } else { 
      return pairs; 
     } 
     }); 
    }) 
    }, Promise.resolve([])); 
} 

これは、最終的にすべてのペアが含まれていますシーケンシャル約束チェーンへiterableを削減します。このような何かを試してみてください。ご使用の環境がそれを可能にしている場合

、あなたも非同期機能にいくつかの変更を使用して機能を変換することができます：

generateDataPoints: async function (iterable, source, arg) { 
    let pairs = [] 
    let prevTime = 0 
    for (let index in iterable) { 
    let event = iterable[index] 
    const [time, val] = await Promise.all([ 
     getTime(event.valueOf()), 
     query(source[arg], event.valueOf()) 
    ]); 
    if (time !== prevTime) { 
     prevTime = time 
     pairs.push([time, val]) 
    } 
    } 
    return pairs; 
} 

編集：

を詳しく見では、それはしていませんこれらの約束を逐次化する必要があるように見えます。

function generateDataPoints(iterable, source, arg) { 
    Promise.all(
    [...iterable].map(event => Promise.all([ 
     getTime(event.valueOf()), 
     query(source[arg], event.valueOf()) 
    ]) 
).then(pairs => { 
    let prevTime = 0 
    return pairs.filter(([time, val]) => { 
     if (time !== prevTime) { 
     prevTime = time; 
     return true; 
     } else { 
     return false; 
     } 
    }); 
    }); 
}