oceanprotocol/ocean.js
1
0
Fork 0
mirror of https://github.com/oceanprotocol/ocean.js.git synced 2024-11-26 20:39:05 +01:00
Code Releases Activity

fix getPoolLogs

Browse Source
This commit is contained in:
alexcos20 2020-11-12 10:28:37 -08:00
parent 31fccf7af3
commit be33814f61
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/balancer/OceanPool.ts
View File

@ -1072,7 +1072,7 @@ export class OceanPool extends Pool {
fromBlock: this.startBlock,
toBlock: 'latest'
})
// since getPoolLogs returns an array we have to push [j][k]
let promises = []
for (let i = 0; i < events.length; i++) {
promises.push(
@ -1081,7 +1081,7 @@ export class OceanPool extends Pool {
if (promises.length > MAX_AWAIT_PROMISES) {
const data = await Promise.all(promises)
for (let j = 0; j < data.length; j++) {
results.push(data[j])
for (let k = 0; k < data.length; k++) results.push(data[j][k])
}
promises = []
}
@ -1089,7 +1089,7 @@ export class OceanPool extends Pool {
if (promises.length > 0) {
const data = await Promise.all(promises)
for (let j = 0; j < data.length; j++) {
results.push(data[j])
for (let k = 0; k < data.length; k++) results.push(data[j][k])
}
promises = []
}