feature(IpfsClient): Efficient processing of large/continuous responses

Start processing the response when the headers are received. This also stops buffering of large content.
richardschneider · Oct 23, 2017 · 81fea3a · 81fea3a
1 parent f2e0524
commit 81fea3a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/IpfsClient.cs b/src/IpfsClient.cs
@@ -294,7 +294,9 @@ public async Task<string> PostCommandAsync(string command, string arg = null, pa
             var url = BuildCommand(command, arg, options);
             if (log.IsDebugEnabled)
                 log.Debug("POST " + url.ToString());
-            using (var response = await Api().PostAsync(url, null))
+            var request = new HttpRequestMessage(HttpMethod.Post, url);
+
+            using (var response = await Api().SendAsync(request, HttpCompletionOption.ResponseHeadersRead))
             {
                 await ThrowOnErrorAsync(response);
                 var body = await response.Content.ReadAsStringAsync();
@@ -355,7 +357,9 @@ public async Task<Stream> PostDownloadAsync(string command, string arg = null, p
             var url = BuildCommand(command, arg, options);
             if (log.IsDebugEnabled)
                 log.Debug("POST " + url.ToString());
-            var response = await Api().PostAsync(url, null);
+            var request = new HttpRequestMessage(HttpMethod.Post, url);
+
+            var response = await Api().SendAsync(request, HttpCompletionOption.ResponseHeadersRead);
             await ThrowOnErrorAsync(response);
             return await response.Content.ReadAsStreamAsync();
         }