У меня есть последовательный источник данных, представленный в виде простого итератора (или потока).Данные довольно большие и не умещаются в памяти.Кроме того, источник может быть пройден один раз и требует больших затрат.Этот источник используется в какой-то тяжелой процедуре (черный ящик), которая принимает Iterator (или Stream) в качестве аргумента для линейного потребления данных.Хорошо, это просто.Но что я могу сделать, если у меня есть две разные такие процедуры потребления?Как я уже сказал, я не хочу засасывать входные данные в коллекцию, например ListЯ также могу выполнить свою задачу, перечитав источник дважды с самого начала, но мне это не нравится, потому что он не эффективен.На самом деле мне нужно «тройник» (своего рода клон) итератор (или поток), чтобы использовать один дважды два параллельных процесса, не кэшируя его в коллекции памяти.Я полагаю, что такой подход должен оказывать противодавление или, скорее, ограничивать родного брата, если он слишком быстро потребляет исходный поток.Возможно, эффективное решение должно иметь некоторый параллельный безопасный буфер очереди.Кто-нибудь знает, как это сделать в Scala (или с использованием любых внешних потоковых библиотек / фреймворков)?
PS Я нашел похожий вопрос на 4 года: Один восходящий поток, питающий несколько нисходящих потоков Разница в том, что я спрашиваю, как это сделать, используя стандартные итераторы Scala (или Streams) или, что лучше, какую-нибудь существующую библиотеку.