Что не так с кодом async\await?

Question

[tuxx]

Есть код:

let Load = (item, config) =>
{
	return new Promise((resolve, reject) =>
	{
		let link = "URL";
		
		Request.get(link, {timeout: 5 * second}, (err, response, body) =>
		{
			if(err)
			{
				reject(err);
			}
			else
			{
				resolve(body);
			}
		});
	});
};

let AwaitLoad = async (item, config) =>
{
	let result = await LoadSteamPrice(item, config);
	console.log(result);

	return result;
};

Вызов AwaitLoad идет в forEach:

Info.forEach(item =>
{
	let result = AwaitLoad(item, config);
	console.log(result);
});

// далее должен быть еще код по обработке Info и всякого другого в синхронном порядке

То есть мне нужно последовательно обратиться по определенным адресам и получить оттуда информацию. И часть полученно информации добавить к элементам из Info. console.log в forEach возвращает Promise { <pending> }, но при этом после отработки console.log в AwaitLoad нужный мен результат выполнения.

Загрузить их все параллельно через Promise.all не могу, т.к. уже 3-4 параллельных запроса возвращают ответ 429 Too many requests, а при последовательном опросе могу хоть сотню запросов отправить.

После этого forEach мне нужно обработать Info далее в синхронном порядке.

Node.js v8.1.2

Answer 1

[Николай]

В цикле нужен тоже await. А в функции самой можно убрать, если там просто return foo(a,b)

Comments

[tuxx]

Если делать так:

let AwaitLoad = async (item, config) =>
{
	return Load(item, config);
};

Info.forEach(item =>
{
	let result = await AwaitSteam(item, config);
	console.log(result);
});

То ругается

let result = await AwaitLoad(item, config);
                   ^^^^^^^^^

SyntaxError: Unexpected identifier
    at createScript (vm.js:74:10)
    at Object.runInThisContext (vm.js:116:10)
    at Module._compile (module.js:533:28)
    at Object.Module._extensions..js (module.js:580:10)
    at Module.load (module.js:503:32)
    at tryModuleLoad (module.js:466:12)
    at Function.Module._load (module.js:458:3)
    at Function.Module.runMain (module.js:605:10)
    at startup (bootstrap_node.js:158:16)
    at bootstrap_node.js:575:3

[Николай]

Ну да, логично. Функция то у вас не async.
А если поставить Async - будет всё сразу выполняться. forEach не подойдет видимо. Сделайте обычный цикл, внутри которого будет цикл. Вот если что для спавки: https://stackoverflow.com/questions/37576685/using...

[tuxx]

Николай: не очень понимаю куда можно вставить async если AwaitLoad уже async
let AwaitLoad = async (item, config) =>
Если только Load переписать типа такого

let Load = async (item, config) =>
{
  await new Promise((resolve, reject) =>
  {
    let link = "URL";
    
    Request.get(link, {timeout: 5 * second}, (err, response, body) =>
    {
      if(err)
      {
        reject(err);
      }
      else
      {
        resolve(body);
      }
    });
  });
};

Но так результат тот что и в моем вопросе.

Ссылочка битая

[Николай]

Ну await может быть только внутри async функции. Для forEach это бы так выглядело:
Только смысла в этом нет никакого, т.к. не будет последовательного выполнения.

arr.forEach( async function() {
    await ....;
}

Вместо этого надо написать как-то так:

for (item of arr) {
   let result = await ...;
}

p.s. ссылка вот: https://stackoverflow.com/questions/37576685/using...

[tuxx]

Переписал AwaitLoad и вроде бы работает как надо

let AwaitLoad = async (Info, config) =>
{
	for(let i = 0, len = Info.length; i < len; i++)
	{
		let result = await Load(item, config);
		// обработка результата
	}
	
	return Info;
};

// вызов AwaitLoad
AwaitSteam(offer, config)
.then(Info =>
{
	// обработка Info
});