Есть ли что-то вроде «противоположности» урожая?

Question

Я признаю, что не могу хранить свои полные данные в памяти, поэтому я хочу передавать части в память и работать с ними, а затем записывать их обратно.

Выход очень полезно ключевое слово, оно сохраняет всю кучу, используя перечислитель и сохранение индекса, ....

Но когда я хочу, чтобы переместить IEnumerable через выход вокруг и записать их обратно в коллекцию/file Мне нужно использовать концепцию перечислителя или есть что-то подобное, как противоположность доходности? Я возглавляю RX, но я не понимаю, решает ли он мою проблему?

public static IEnumerable<string> ReadFile() 
    { 
     string line; 

     var reader = new System.IO.StreamReader(@"c:\\temp\\test.txt"); 
     while ((line = reader.ReadLine()) != null) 
     { 
      yield return line; 
     } 

     reader.Close(); 
    } 

    public static void StreamFile() 
    { 
     foreach (string line in ReadFile()) 
     { 
      WriteFile(line); 
     } 
    } 

    public static void WriteFile(string line) 
    { 
     // how to save the state, of observe an collection/stream??? 
     var writer = new System.IO.StreamWriter("c:\\temp\\test.txt"); 
     writer.WriteLine(line); 

     writer.Close(); 
    } 

Answer 1

В вашем случае, вы можете передать IEnumerable<string> непосредственно WriteFile:

public static void WriteFile(IEnumerable<string> lines) 
{ 
    // how to save the state, of observe an collection/stream??? 
    using(var writer = new System.IO.StreamWriter("c:\\temp\\test.txt")) 
    { 
     foreach(var line in lines) 
      writer.WriteLine(line); 
    } 
} 

Поскольку вход в потоковом через IEnumerable<T>, данные никогда не будут храниться в памяти.

Обратите внимание, что в этом случае вы можете просто использовать File.ReadLines для выполнения чтения, поскольку он уже передает результаты обратно через IEnumerable<string>. С File.WriteAllLines, ваш код может быть сделано (хотя, вы могли бы просто использовать File.Copy):

File.WriteAllLines(outputFile, File.ReadLines(inputFile));