Процесс загрузки данных асинхронный

Question

Есть ли простой способ обработки загруженных данных во время загрузки? Я не хочу ждать завершения загрузки, чтобы перед обработкой иметь все данные на памяти или диске. Я хочу сделать это, потому что мои данные сжаты, и я хотел бы распаковать байтовые пакеты в прогоне и записать их прямо на диск. Чтобы я никогда не использовал больше памяти, чем один пакет загрузки.

Я пытался ужиться с классом WebClient, но я не узнал, как получить доступ к последним загруженным байтам в событии DownloadProgressChanged.

Что-то вроде этого:

WebClient wc = new WebClient(); 
Uri uri = new Uri(myURL); 
wc.DownloadProgressChanged += wc_DownloadProgressChanged; 
wc.DownloadDataAsync(uri); 

... 

void wc_DownloadProgressChanged(object sender, DownloadProgressChangedEventArgs e) 
{ 
    ProcessData(e.Bytes,e.BytesReceived); //e.Bytes should access the downloaded byte packet 
    //but it doesn't exist 
} 

Я понял это уже с помощью Libcurl, но я хотел бы знать, если это возможно без использования внешних библиотек.

Answer 1

не имели возможность протестировать его, но она могла бы работать что-то вроде этого:

public void DownloadFileAsync() 
    { 
     WebClient wc = new WebClient(); 
     Uri uri = new Uri(myURL); 
     //Open Stream from URI 
     wc.OpenReadCompleted += new OpenReadCompletedEventHandler(OpenReadCallback); 
     wc.OpenReadAsync(uri); 
    } 


    private static void OpenReadCallback(Object sender, OpenReadCompletedEventArgs e) 
    { 
     Stream resStream = null; 

     try 
     { 
      resStream = (Stream)e.Result; 
      //Your decompression stream Gzip for example 
      using (GZipStream compressionStream = new GZipStream(resStream, CompressionMode.Decompress)) 
      { 
       //write gzip stream to file 
       using (
        FileStream outFile = new FileStream(@"c:\mytarget.somefile", FileMode.Create, FileAccess.Write, 
         FileShare.None)) 
         compressionStream.CopyTo(outFile); 
      } 
     } 
     finally 
     { 
      if (resStream != null) 
      { 
       resStream.Close(); 
      } 
     } 
    }