in agent/agent-activationdb.js [57:88]
async function pollActivations(actionName, onActivation, onLoop) {
const wsk = openwhisk();
const since = Date.now();
while (true) {
let name = actionName;
if (activationListFilterOnlyBasename) {
if (actionName.includes("/")) {
name = actionName.substring(actionName.lastIndexOf("/") + 1);
}
}
const activations = await wsk.activations.list({
name: name,
since: since,
docs: true // include results
});
for (const a of activations) {
const result = onActivation(a);
if (result) {
return result;
}
}
await sleep(1000);
onLoop();
}
}