#typescript
Вопрос:
Я хотел бы иметь возможность взять поток fs.read и загрузить его с повторными попытками, но поток непригоден для использования после первой попытки.
const buf = fs.createReadStream(filePath) for (let i = 0; i lt; times; i ) { try { await upload(buf) }catch(e){ console.log(e) } } Комментарии:
1. Почему? Потоки работают не так… Чего вы пытаетесь достичь?
2. Я создаю библиотеку для пользователей, чтобы загружать поток в мой сервис, я хочу сам создать механизм повторных попыток
Ответ №1:
В итоге я нашел это лучшее для меня решение: запишите strean в массив (используя библиотеку потоков-массивов) и передайте массив потоком (используя поток в массив). Таким образом, я могу использовать массив столько раз, сколько захочу, для разных применений, не беспокоясь о том, что цепочка каналов выйдет из строя, если одна из них выйдет из строя.