コンテンツが100％完成する前にHttpResponseMessageからヘッダーを読み取る

Question

1. 応答ヘッダーにアクセスするにはどうすればよいですか？
2. ストリームの到着時にストリームを読み取るにはどうすればよいですか？
3. HTTP応答を受信するようなきめ細かな制御のためにHttpClientが最良の選択ですか？ 、私は発掘
   いずれの参照がブロッキング文のいくつかの種類があります：私のために別の灰色の領域を明確にするために

   using (var response = await _httpClient.SendAsync(request, 
       HttpCompletionOption.ResponseHeadersRead)) 
   { 
       var streamTask = response.Content.ReadAsStreamAsync(); 
       //how do I check if headers portion has completed? 
       //Does HttpCompletionOption.ResponseHeadersRead guarantee that? 
       //pseudocode 
       while (!(all headers have been received)) 
       //maybe await a Delay here to let Headers get fully populated 
       access_headers_without_causing_entire_response_to_be_received 
   
       //how do I access the response, without causing an await until contents downloaded? 
       //pseudocode 
       while (stremTask.Resul.?) //i.e. while something is still streaming 
       //? what goes here? a chunk-read into a buffer? or line-by-line since it's http? 
       ... 
   

   
   編集：

は、ここに私の質問を説明するかもしれないスニップです内容が到着するのを待つ原因となる。 参考文献私は通常、streamTask.ResultまたはContentのアクセスメソッドまたはプロパティを読み込み、streamTaskが進行中であるときにそのような参照が大丈夫であるかどうかを判断するのに十分ではないタスクが完了しました。

Answer 1

私自身のテストに基づいて、コンテンツストリームの読み取りを開始するまではコンテンツは転送されず、Task.Resultという呼び出しがブロッキングコールであることが間違いありませんが、その性質上、同期点です。 しかしは、コンテンツ全体をプリバッファリングするのをブロックしません。コンテンツがサーバから来るようになるまでブロックします。

無限のストリームは無限の時間ブロックされません。そのため、ストリームを非同期的にフェッチしようとすると、特にヘッダー処理操作が比較的短い場合には、過剰なものとみなされる可能性があります。しかし、必要ならば、コンテンツストリームが別のタスクで処理されている間は、常にヘッダーを処理できます。これのようなものはそれを達成するでしょう。ヘッダ部分が完了したかどうかを確認する必要がないことを

static void Main(string[] args) 
{ 
    var url = "http://somesite.com/bigdownloadfile.zip"; 
    var client = new HttpClient(); 
    var request = new HttpRequestMessage(HttpMethod.Get, url); 

    var getTask = client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead); 
    Task contentDownloadTask = null; 

    var continuation = getTask.ContinueWith((t) => 
    { 
     contentDownloadTask = Task.Run(() => 
     { 
      var resultStream = t.Result.Content.ReadAsStreamAsync().Result; 
      resultStream.CopyTo(File.Create("output.dat")); 
     }); 

     Console.WriteLine("Got {0} headers", t.Result.Headers.Count()); 
     Console.WriteLine("Blocking after fetching headers, press any key to continue..."); 
     Console.ReadKey(true); 
    }); 

    continuation.Wait(); 
    contentDownloadTask.Wait(); 
    Console.WriteLine("Finished downloading {0} bytes", new FileInfo("output.dat").Length); 

    Console.WriteLine("Finished, press any key to exit"); 
    Console.ReadKey(true); 
} 

注は、明示的にHttpCompletionOption.ResponseHeadersReadオプションであることを指定しました。 SendAsyncタスクは、ヘッダーが取得されるまで続行されません。

Answer 2

結果は、それがさらに読みやすいのawait /非同期のキーワードを使用して：

var url = "http://somesite.com/bigdownloadfile.zip"; 

using (var httpClient = new HttpClient()) 
using (var httpRequest = new HttpRequestMessage(HttpMethod.Get, url)) 
using(HttpResponseMessage response = await httpClient.SendAsync(httpRequest, HttpCompletionOption.ResponseHeadersRead)) 
using (Stream stream = await response.Content.ReadAsStreamAsync()) 
{ 
    //Access to the Stream object as it comes, buffer it or do whatever you need 
}