Я пытаюсь создать Дуплексный поток, который получает несколько объектов, реорганизует их, а затем передает их в любой поток, который читается из моего потока. Боли в том, что часть чтения должна начинаться только после того, как все объекты были получены (другими словами, после финишного события).Как оживить поток Дуплекс до завершения события завершения, чтобы начать отправку данных?
Как я могу это сделать?
Моя нынешняя идея заключается в том, что у меня было бы два разных потока (вместо дуплекса), и я просто разъясню свой API, что Readable stream не должен использоваться до того, как поток Writable сообщает вам сделать это - но это кажется настолько неправильным!
Итак, пожалуйста, есть ли лучший способ сделать это? Спасибо заранее.