выполнение socket.io в цикле

130

15 мая 2019, 09:50

Столкнулся с такой проблемой при использовании socket.io: есть цикл в нем находится socket.emit('event', callback) у меня не получается дождаться ответа от on и обрабатывается только последнее значение цикла. Как мне дождаться ответа socket.emit и дождаться выполнения и после выполнения продолжать перебор цикла. пробовал async / await, не помогает

Серверная часть:

socket.on ('GetProducts',  (params, callback) => {
    idCat =  params['idCat'];
    var url = 'страница json'
     http.get (url, res => {
      res.setEncoding ('utf8');
      var body = '';
       res.on ('data', data => {
        body += data;
      });
      res.on ('end',  () => {
        json =  JSON.parse (body);
        callback (json);
      });
    });
  });
});

Клиентская часть:

function ControlChecked () {
  $ ('#tableListProductLeads').empty ();
  socket = [];
  $ ('#tableCategoreLeads > tr > th > input').each ( (index, element) => {
    if ($ (element).is (':Checked')) {
      socket[index] =  io (ArdServ);
      idCat =  $ (element).attr ('idCat');
       socket[index].emit ('GetProductsLeads', {idCat},  data => {
        data =  data['data'];
          FilltableListProductLeads (data, idCat);
      });
    }
  });
}

Answer 1

Если я правильно понял, то вы в цикле плодите новые сокеты? Может достаточно одного и создать событие на клиенте для прослушивания ответа?

Переделайте так:

Серверная часть:

socket.on ('GetProducts',  (params, callback) => {
    idCat =  params['idCat'];
    var url = 'страница json'
     http.get (url, res => {
      res.setEncoding ('utf8');
      var body = '';
       res.on ('data', data => {
        body += data;
      });
      res.on ('end',  () => {
        json =  JSON.parse (body);
        callback (json);
      });
    });
  });
});

Клиентская часть:

function ControlChecked () {
  $ ('#tableListProductLeads').empty ();
  socket = [];
  $ ('#tableCategoreLeads > tr > th > input').each ( (index, element) => {
    if ($ (element).is (':Checked')) {
      socket[index] =  io (ArdServ);
      idCat =  $ (element).attr ('idCat');
      GetProductsLeads(socket[index], idCat);
    }
  });
}
function GetProductsLeads(socket, id) {
    socket.emit ('GetProductsLeads', {id},  data => {
       data =  data['data'];
       FilltableListProductLeads (data, id);
    });
}