F#? Эта библиотека позволяет создавать стримы, которые позволяют обрабатывать данные по мере их поступления — т.е. на ходу. Ну например, если у меня есть большой файл с какими-то сущностями, и есть пайплайн по их обработке (конвертации во что-то, дальнейшей десиаризации во что-то другое и запись в другой файл), то такая библиотека позволяет читать и одновременно конвертировать файл и писать новые данные, таким образом расход по памяти минимален. Ну т.е. как только одна энтити десериализовалась из исходного файла, а не весь файл, она ушла в обработку и тут же записалась в выходной файл.
AsyncSeq Hopac.Streams https://github.com/Open-NET-Libraries/Open.ChannelExtensions
Обсуждают сегодня