Мне интересно, есть ли какой-нибудь идиоматический способ объединить несколько входных потоков в один непрерывный входной поток в Java (или Scala).
Мне это нужно для анализа плоских файлов, которые Загружаюсь по сети с FTP-сервера. Я хочу взять файлы [1..N], открыть потоки, а затем объединить их в один поток. Поэтому, когда файл 1 подходит к концу, я хочу начать чтение с файла 2 и так далее, пока не дойду до конца файла N.
Мне нужно прочитать эти файлы в конкретный заказ. Данные поступают из устаревшей системы, которая создает файлы в пакетном режиме, поэтому данные в одном файле зависят от данных в другом файле, но я хотел бы обрабатывать их как один непрерывный поток, чтобы упростить логический интерфейс моей предметной области.
Я поискал и нашел PipedInputStream, но не уверен, что это то, что мне нужно. Пример был бы полезен.
Подробнее здесь: https://stackoverflow.com/questions/142 ... nputstream