調用另一個流內容web api方法的Web api方法？

Question

這是我的情況我有兩個web api服務。第一種方法有處理一些數據的方法，當部分數據準備就緒時，它將其推送到流中。

public HttpResponseMessage Get() 
     { 
      var response = Request.CreateResponse(); 
      response.Content = new PushStreamContent(WriteToStream); 
      return response; 
     } 

     public async void WriteToStream(Stream outputStream, HttpContent content, TransportContext context) 
     { 
      ....... 
     } 

第二個web api在調用第一個web api的控制器中有一個方法。它必須讀取的部分從流用它做的東西，把我給它自己的流：

public HttpResponseMessage Get() 
     { 
      Stream stream = null; 

      using(HttpClient httpClient = new HttpClient()) 
      { 
       httpClient.Timeout = TimeSpan.FromMilliseconds(Timeout.Infinite); 
       HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, "http://localhost/fistWebApi/"); 

       var response = httpClient.SendAsync(request, HttpCompletionOption.ResponseContentRead); 

       var content = response.Result.Content.ReadAsStreamAsync(); 

       stream = content.Result; 
      } 

      var msg = Request.CreateResponse(); 

      msg.Content = new PushStreamContent(WriteToStream); 

      return msg; 
     } 
public async void WriteToStream(Stream outputStream, HttpContent content, TransportContext context) 
      { 
       ....... 
      } 

的問題是，我不知道如何調用SendAsyncReadAsStreamAsync同步。現在它不會等待，並且stream在嘗試使用時未正確初始化。我希望第二個方法的代碼等待，直到第一個方法將部分數據放到流中。我嘗試使用ContinueWith，但後來我無法做到。我知道這是一個模糊的解釋，如果有任何問題我會試着更深入地解釋。

Answer 1

嘗試......

public HttpResponseMessage Get() 
     { 

      using (HttpClient httpClient = new HttpClient()) 
      { 
       httpClient.Timeout = TimeSpan.FromMilliseconds(Timeout.Infinite); 
       HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, "http://www.google.ca"); 

       return httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead) 
        .ContinueWith((t) => 
         { 
          return new HttpResponseMessage() 
           { 
            Content = t.Result.Content 
           }; 
         }).Result; 

      } 

     } 

上面的代碼爲我工作。這樣做的缺點是，因爲你使用了HttpCompletionOption.ResponseContentRead，所以來自遠程服務的整個有效負載在返回客戶端之前將被緩衝。

如果您改爲使用HttpCompletionOption.ResponseHeadersRead，t.Result.Content將返回網絡流。這樣，當您的客戶端拉取響應流時，它將直接從遠程資源進行流式傳輸。我假設你正在試圖用你正在返回的PushStreamContent做什麼。