|
@ -486,6 +486,7 @@ function onCollection(err, collection) { |
|
|
}); |
|
|
}); |
|
|
})() //await inside yes
|
|
|
})() //await inside yes
|
|
|
}else{ |
|
|
}else{ |
|
|
|
|
|
(async() => { |
|
|
await pubClient.get(pathfileval, function(err, object) { |
|
|
await pubClient.get(pathfileval, function(err, object) { |
|
|
var objecttmp = JSON.parse(object); |
|
|
var objecttmp = JSON.parse(object); |
|
|
var resob1 = {} |
|
|
var resob1 = {} |
|
@ -511,6 +512,7 @@ function onCollection(err, collection) { |
|
|
itemsProcessed++; |
|
|
itemsProcessed++; |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
|
|
|
})() //await inside no
|
|
|
} |
|
|
} |
|
|
}); //redis get
|
|
|
}); //redis get
|
|
|
})() //async
|
|
|
})() //async
|
|
|