Добавление вилок после запуска потока?
У меня есть приложение node.js, использующее поток Highland. Он использует источник данных и должен отправлять данные в несколько пунктов назначения. Проблема в том, что места назначения обнаруживаются динамически путем чтения данных и создания потоков назначения на основе данных.
Это значит я не могу .fork поток для добавления пунктов назначения (потому что поток, который начал потреблять, не может быть разветвлен, верно?)
Есть ли что-нибудь еще, что я могу сделать?
Мой нынешний подход заключается в том, чтобы иметь .consume где я создаю потоки назначения и записываю данные в места назначения. Результат уродлив и грязен.