diff --git a/src/OpenSearch.Net/Connection/HttpConnection.cs b/src/OpenSearch.Net/Connection/HttpConnection.cs index dfb8506fd9..bb9d4eb598 100644 --- a/src/OpenSearch.Net/Connection/HttpConnection.cs +++ b/src/OpenSearch.Net/Connection/HttpConnection.cs @@ -107,8 +107,9 @@ public virtual TResponse Request(RequestData requestData) if (requestData.ThreadPoolStats) threadPoolStats = ThreadPoolStats.GetStats(); - - responseMessage = client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead).GetAwaiter().GetResult(); + var task = Task.Run(() => client.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead)); + task.Wait(); + responseMessage = task.Result; statusCode = (int)responseMessage.StatusCode; d.EndState = statusCode; } @@ -120,7 +121,9 @@ public virtual TResponse Request(RequestData requestData) if (responseMessage.Content != null) { receive = DiagnosticSource.Diagnose(DiagnosticSources.HttpConnection.ReceiveBody, requestData, statusCode); - responseStream = responseMessage.Content.ReadAsStreamAsync().GetAwaiter().GetResult(); + var task = Task.Run(() => responseMessage.Content.ReadAsStreamAsync()); + task.Wait(); + responseStream = task.Result; } } catch (TaskCanceledException e)