问题描述
我有类似的东西
new Promise (resolve, reject) ->
trader.getTrades limit, skip, (err, trades) ->
return reject err if err
resolve trades
.each (trade) ->
doStuff trade
限制
是设置为某个任意数字,例如 10
和 skip
从 0开始
。我想继续增加跳过
,直到不再有交易
。
limit
is set to some arbitrary number, say 10
and skip
starts at 0
. I want to keep increasing skip
until there are no more trades
.
doStuff
是我用来处理每笔交易的函数。
The doStuff
is a function I'm using to process each trade.
这是第一个工作时间,但我希望以分页的方式获得更多交易。具体来说,我想运行 trader.getTrades
,使用更高的跳过
,直到 trades.length
是0
This works the first time, but I want to get more trades in a paginated fashion. Specifically, I want to run trader.getTrades
with a higher skip
until trades.length
is 0
推荐答案
您应该可以使用将 trader.getTrades()
转换为返回promise的异步版本。然后,这样的事情应该运作良好:
You should be able to use promisify()
/promisifyAll()
to convert trader.getTrades()
to an async version that returns a promise. Then, something like this should work well:
function getAllTrades(limit, offset, query) {
var allTrades = [];
function getTrades(limit, offset, query){
return trader.getTradesAsync(limit, offset, query)
.each(function(trade) {
allTrades.push(trade)
// or, doStuff(trade), etc.
})
.then(function(trades) {
if (trades.length === limit) {
offset += limit;
return getTrades(limit, offset, query);
} else {
return allTrades;
}
})
.catch(function(e) {
console.log(e.stack);
})
}
return getTrades(limit, offset, query)
}
如果你事先了解交易总数,你可以使用不同的策略与 .map
和 {concurrency:N}
一次获得N页交易。
If you knew the total # of trades in advance you could use a different strategy with .map
and {concurrency: N}
to get N pages of trades at once.
这篇关于如何与Bluebird Promises进行分页?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!