CarterSS
Сейчас главный вопрос чтобы эта подзадача не тормозила работу сокетов с клиентами, да и сам сокет должен быть неблокирующим.
Так и не надо сидеть в обработчике события sock.on.
Я сделал вот так:
socket.on('join', function (data) {
streams.push(sock); //Добавляем новый сокет в массив потоков
генерим событие ('обработать join' для streams.нашсокет) )
});
обработчик события 'join'
{
NewTask(data); =>Обработка данных
, подключение к устройствам, получение ответа от устройств.
// Отправляем клиенту, что задача выполнена
}