From 451d810aded126fe5280ac64829f38f8c85cf76d Mon Sep 17 00:00:00 2001 From: Paul Schneider Date: Sun, 11 Jul 2021 19:20:56 +0100 Subject: [PATCH] using async methods --- src/isn/UploadFilesToServerUsingWebRequest.cs | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/src/isn/UploadFilesToServerUsingWebRequest.cs b/src/isn/UploadFilesToServerUsingWebRequest.cs index d72c954..e3831af 100644 --- a/src/isn/UploadFilesToServerUsingWebRequest.cs +++ b/src/isn/UploadFilesToServerUsingWebRequest.cs @@ -17,7 +17,7 @@ namespace nuget_cli { /// - /// Creates HTTP POST request & uploads database to server. Author : Farhan Ghumra + /// Creates HTTP POST request & uploads database to server. Author : Farhan Ghumra /// internal async Task UploadFilesToServerAsync(PushReport report, Uri uri, FileInfo fi, string apikey) @@ -46,7 +46,7 @@ namespace nuget_cli fileheaderbytes.Length + fi.Length + endBoundaryBytes.Length; - httpWebRequest.BeginGetRequestStream((result) => + httpWebRequest.BeginGetRequestStream(async (result) => { try { @@ -54,22 +54,21 @@ namespace nuget_cli using (Stream requestStream = request.EndGetRequestStream(result)) { - WriteToStream(requestStream, boundarybytes, boundarybytes.Length); - WriteToStream(requestStream, fileheaderbytes, fileheaderbytes.Length); + await WriteToStream(requestStream, boundarybytes, boundarybytes.Length); + await WriteToStream(requestStream, fileheaderbytes, fileheaderbytes.Length); using (var fss = fi.OpenRead()) { byte[] buffer = new byte[TXLEN]; var form_bytes_read = fss.Read(buffer, 0, TXLEN); while (form_bytes_read > 0) { - WriteToStream(requestStream, buffer, form_bytes_read); + await WriteToStream(requestStream, buffer, form_bytes_read); form_bytes_read = fss.Read(buffer, 0, TXLEN); } } requestStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length); requestStream.Close(); } - } catch (Exception rex) { @@ -82,13 +81,13 @@ namespace nuget_cli } }, httpWebRequest); - WebResponse resp = httpWebRequest.GetResponse(); + WebResponse resp = await httpWebRequest.GetResponseAsync(); Stream stream = resp.GetResponseStream(); StreamReader re = new StreamReader(stream); if (resp is HttpWebResponse) { - String json = re.ReadToEnd(); + String json = await re.ReadToEndAsync(); report.Message = json; var hrep = resp as HttpWebResponse; report.StatusCode = hrep.StatusCode.ToString(); @@ -101,9 +100,9 @@ namespace nuget_cli /// /// Writes byte array to stream. Author : Farhan Ghumra /// - private static void WriteToStream(Stream s, byte[] bytes, int len) + private static async Task WriteToStream(Stream s, byte[] bytes, int len) { - s.Write(bytes, 0, len); + await s.WriteAsync(bytes, 0, len); } } } \ No newline at end of file