diff --git a/src/generated/IKubernetes.cs b/src/generated/IKubernetes.cs index bd509cf7c..74e3ae438 100644 --- a/src/generated/IKubernetes.cs +++ b/src/generated/IKubernetes.cs @@ -6713,7 +6713,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Pod @@ -6730,7 +6730,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Pod @@ -6747,7 +6747,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Pod @@ -6764,7 +6764,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Pod @@ -6781,7 +6781,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Pod @@ -6798,7 +6798,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy GET requests to Pod @@ -6818,7 +6818,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Pod @@ -6838,7 +6838,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Pod @@ -6858,7 +6858,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Pod @@ -6878,7 +6878,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Pod @@ -6898,7 +6898,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Pod @@ -6918,7 +6918,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy GET requests to Service @@ -6935,7 +6935,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Service @@ -6952,7 +6952,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Service @@ -6969,7 +6969,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Service @@ -6986,7 +6986,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Service @@ -7003,7 +7003,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Service @@ -7020,7 +7020,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy GET requests to Service @@ -7040,7 +7040,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Service @@ -7060,7 +7060,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Service @@ -7080,7 +7080,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Service @@ -7100,7 +7100,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Service @@ -7120,7 +7120,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Service @@ -7140,7 +7140,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy GET requests to Node @@ -7154,7 +7154,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Node @@ -7168,7 +7168,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Node @@ -7182,7 +7182,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Node @@ -7196,7 +7196,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Node @@ -7210,7 +7210,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Node @@ -7224,7 +7224,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy GET requests to Node @@ -7241,7 +7241,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyGETNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyGETNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PUT requests to Node @@ -7258,7 +7258,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPUTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPUTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy POST requests to Node @@ -7275,7 +7275,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPOSTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPOSTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy DELETE requests to Node @@ -7292,7 +7292,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyDELETENodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyDELETENodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy HEAD requests to Node @@ -7309,7 +7309,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyHEADNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyHEADNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// proxy PATCH requests to Node @@ -7326,7 +7326,7 @@ public partial interface IKubernetes : System.IDisposable /// /// The cancellation token. /// - Task> ProxyPATCHNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> ProxyPATCHNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// list or watch objects of kind ReplicationController diff --git a/src/generated/Kubernetes.cs b/src/generated/Kubernetes.cs index ca449950b..574d9ccdd 100644 --- a/src/generated/Kubernetes.cs +++ b/src/generated/Kubernetes.cs @@ -36009,7 +36009,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36070,7 +36070,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -36101,26 +36101,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36159,7 +36146,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36220,7 +36207,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -36251,26 +36238,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36309,7 +36283,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36370,7 +36344,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -36401,26 +36375,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36459,7 +36420,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36520,7 +36481,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -36551,26 +36512,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36609,7 +36557,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36701,26 +36649,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36759,7 +36694,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNamespacedPodWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36820,7 +36755,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -36851,26 +36786,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -36912,7 +36834,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -36979,7 +36901,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37010,26 +36932,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37071,7 +36980,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37138,7 +37047,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37169,26 +37078,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37230,7 +37126,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37297,7 +37193,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37328,26 +37224,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37389,7 +37272,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37456,7 +37339,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37487,26 +37370,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37548,7 +37418,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37646,26 +37516,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37707,7 +37564,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37774,7 +37631,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37805,26 +37662,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -37863,7 +37707,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -37924,7 +37768,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -37955,26 +37799,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38013,7 +37844,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38074,7 +37905,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -38105,26 +37936,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38163,7 +37981,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38224,7 +38042,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -38255,26 +38073,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38313,7 +38118,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38374,7 +38179,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -38405,26 +38210,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38463,7 +38255,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38555,26 +38347,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38613,7 +38392,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNamespacedServiceWithHttpMessagesAsync(string name, string namespaceParameter, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38674,7 +38453,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -38705,26 +38484,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38766,7 +38532,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38833,7 +38599,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -38864,26 +38630,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -38925,7 +38678,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -38992,7 +38745,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39023,26 +38776,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39084,7 +38824,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39151,7 +38891,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39182,26 +38922,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39243,7 +38970,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39310,7 +39037,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39341,26 +39068,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39402,7 +39116,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39500,26 +39214,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39561,7 +39262,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(string name, string namespaceParameter, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39628,7 +39329,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39659,26 +39360,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39714,7 +39402,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39769,7 +39457,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39800,26 +39488,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39855,7 +39530,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -39910,7 +39585,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -39941,26 +39616,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -39996,7 +39658,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40051,7 +39713,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40082,26 +39744,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40137,7 +39786,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40192,7 +39841,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40223,26 +39872,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40278,7 +39914,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40364,26 +40000,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40419,7 +40042,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNodeWithHttpMessagesAsync(string name, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40474,7 +40097,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40505,26 +40128,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40563,7 +40173,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyGETNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyGETNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40624,7 +40234,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40655,26 +40265,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40713,7 +40310,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPUTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPUTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40774,7 +40371,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40805,26 +40402,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -40863,7 +40447,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPOSTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPOSTNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -40924,7 +40508,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -40955,26 +40539,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -41013,7 +40584,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyDELETENodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyDELETENodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -41074,7 +40645,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -41105,26 +40676,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -41163,7 +40721,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyHEADNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyHEADNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -41255,26 +40813,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { @@ -41313,7 +40858,7 @@ private void Initialize() /// /// A response object containing the response body and response headers. /// - public async Task> ProxyPATCHNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> ProxyPATCHNodeWithPathWithHttpMessagesAsync(string name, string path, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (name == null) { @@ -41374,7 +40919,7 @@ private void Initialize() ServiceClientTracing.SendRequest(_invocationId, _httpRequest); } cancellationToken.ThrowIfCancellationRequested(); - _httpResponse = await HttpClient.SendAsync(_httpRequest, cancellationToken).ConfigureAwait(false); + _httpResponse = await HttpClient.SendAsync(_httpRequest, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); if (_shouldTrace) { ServiceClientTracing.ReceiveResponse(_invocationId, _httpResponse); @@ -41405,26 +40950,13 @@ private void Initialize() throw ex; } // Create Result - var _result = new HttpOperationResponse(); + var _result = new HttpOperationResponse(); _result.Request = _httpRequest; _result.Response = _httpResponse; // Deserialize Response if ((int)_statusCode == 200) { - _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); - try - { - _result.Body = SafeJsonConvert.DeserializeObject(_responseContent, DeserializationSettings); - } - catch (JsonException ex) - { - _httpRequest.Dispose(); - if (_httpResponse != null) - { - _httpResponse.Dispose(); - } - throw new SerializationException("Unable to deserialize the response.", _responseContent, ex); - } + _result.Body = await _httpResponse.Content.ReadAsStreamAsync().ConfigureAwait(false); } if (_shouldTrace) { diff --git a/src/generated/KubernetesExtensions.cs b/src/generated/KubernetesExtensions.cs index 74f0ec180..982c467c7 100644 --- a/src/generated/KubernetesExtensions.cs +++ b/src/generated/KubernetesExtensions.cs @@ -14001,7 +14001,7 @@ public static string ConnectPatchNodeProxyWithPath(this IKubernetes operations, /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyGETNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyGETNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyGETNamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14021,12 +14021,11 @@ public static string ProxyGETNamespacedPod(this IKubernetes operations, string n /// /// The cancellation token. /// - public static async Task ProxyGETNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14041,7 +14040,7 @@ public static string ProxyGETNamespacedPod(this IKubernetes operations, string n /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPUTNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPUTNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPUTNamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14061,12 +14060,11 @@ public static string ProxyPUTNamespacedPod(this IKubernetes operations, string n /// /// The cancellation token. /// - public static async Task ProxyPUTNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14081,7 +14079,7 @@ public static string ProxyPUTNamespacedPod(this IKubernetes operations, string n /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPOSTNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPOSTNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPOSTNamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14101,12 +14099,11 @@ public static string ProxyPOSTNamespacedPod(this IKubernetes operations, string /// /// The cancellation token. /// - public static async Task ProxyPOSTNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14121,7 +14118,7 @@ public static string ProxyPOSTNamespacedPod(this IKubernetes operations, string /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyDELETENamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyDELETENamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyDELETENamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14141,12 +14138,11 @@ public static string ProxyDELETENamespacedPod(this IKubernetes operations, strin /// /// The cancellation token. /// - public static async Task ProxyDELETENamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14161,7 +14157,7 @@ public static string ProxyDELETENamespacedPod(this IKubernetes operations, strin /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyHEADNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyHEADNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyHEADNamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14181,12 +14177,11 @@ public static string ProxyHEADNamespacedPod(this IKubernetes operations, string /// /// The cancellation token. /// - public static async Task ProxyHEADNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14201,7 +14196,7 @@ public static string ProxyHEADNamespacedPod(this IKubernetes operations, string /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPATCHNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPATCHNamespacedPod(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPATCHNamespacedPodAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14221,12 +14216,11 @@ public static string ProxyPATCHNamespacedPod(this IKubernetes operations, string /// /// The cancellation token. /// - public static async Task ProxyPATCHNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNamespacedPodAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNamespacedPodWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14244,7 +14238,7 @@ public static string ProxyPATCHNamespacedPod(this IKubernetes operations, string /// /// path to the resource /// - public static string ProxyGETNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyGETNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyGETNamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14267,12 +14261,11 @@ public static string ProxyGETNamespacedPodWithPath(this IKubernetes operations, /// /// The cancellation token. /// - public static async Task ProxyGETNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14290,7 +14283,7 @@ public static string ProxyGETNamespacedPodWithPath(this IKubernetes operations, /// /// path to the resource /// - public static string ProxyPUTNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPUTNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPUTNamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14313,12 +14306,11 @@ public static string ProxyPUTNamespacedPodWithPath(this IKubernetes operations, /// /// The cancellation token. /// - public static async Task ProxyPUTNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14336,7 +14328,7 @@ public static string ProxyPUTNamespacedPodWithPath(this IKubernetes operations, /// /// path to the resource /// - public static string ProxyPOSTNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPOSTNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPOSTNamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14359,12 +14351,11 @@ public static string ProxyPOSTNamespacedPodWithPath(this IKubernetes operations, /// /// The cancellation token. /// - public static async Task ProxyPOSTNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14382,7 +14373,7 @@ public static string ProxyPOSTNamespacedPodWithPath(this IKubernetes operations, /// /// path to the resource /// - public static string ProxyDELETENamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyDELETENamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyDELETENamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14405,12 +14396,11 @@ public static string ProxyDELETENamespacedPodWithPath(this IKubernetes operation /// /// The cancellation token. /// - public static async Task ProxyDELETENamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14428,7 +14418,7 @@ public static string ProxyDELETENamespacedPodWithPath(this IKubernetes operation /// /// path to the resource /// - public static string ProxyHEADNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyHEADNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyHEADNamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14451,12 +14441,11 @@ public static string ProxyHEADNamespacedPodWithPath(this IKubernetes operations, /// /// The cancellation token. /// - public static async Task ProxyHEADNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14474,7 +14463,7 @@ public static string ProxyHEADNamespacedPodWithPath(this IKubernetes operations, /// /// path to the resource /// - public static string ProxyPATCHNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPATCHNamespacedPodWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPATCHNamespacedPodWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14497,12 +14486,11 @@ public static string ProxyPATCHNamespacedPodWithPath(this IKubernetes operations /// /// The cancellation token. /// - public static async Task ProxyPATCHNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNamespacedPodWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNamespacedPodWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14517,7 +14505,7 @@ public static string ProxyPATCHNamespacedPodWithPath(this IKubernetes operations /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyGETNamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyGETNamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyGETNamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14537,12 +14525,11 @@ public static string ProxyGETNamespacedService(this IKubernetes operations, stri /// /// The cancellation token. /// - public static async Task ProxyGETNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14557,7 +14544,7 @@ public static string ProxyGETNamespacedService(this IKubernetes operations, stri /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPUTNamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPUTNamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPUTNamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14577,12 +14564,11 @@ public static string ProxyPUTNamespacedService(this IKubernetes operations, stri /// /// The cancellation token. /// - public static async Task ProxyPUTNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14597,7 +14583,7 @@ public static string ProxyPUTNamespacedService(this IKubernetes operations, stri /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPOSTNamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPOSTNamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPOSTNamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14617,12 +14603,11 @@ public static string ProxyPOSTNamespacedService(this IKubernetes operations, str /// /// The cancellation token. /// - public static async Task ProxyPOSTNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14637,7 +14622,7 @@ public static string ProxyPOSTNamespacedService(this IKubernetes operations, str /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyDELETENamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyDELETENamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyDELETENamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14657,12 +14642,11 @@ public static string ProxyDELETENamespacedService(this IKubernetes operations, s /// /// The cancellation token. /// - public static async Task ProxyDELETENamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14677,7 +14661,7 @@ public static string ProxyDELETENamespacedService(this IKubernetes operations, s /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyHEADNamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyHEADNamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyHEADNamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14697,12 +14681,11 @@ public static string ProxyHEADNamespacedService(this IKubernetes operations, str /// /// The cancellation token. /// - public static async Task ProxyHEADNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14717,7 +14700,7 @@ public static string ProxyHEADNamespacedService(this IKubernetes operations, str /// /// object name and auth scope, such as for teams and projects /// - public static string ProxyPATCHNamespacedService(this IKubernetes operations, string name, string namespaceParameter) + public static Stream ProxyPATCHNamespacedService(this IKubernetes operations, string name, string namespaceParameter) { return operations.ProxyPATCHNamespacedServiceAsync(name, namespaceParameter).GetAwaiter().GetResult(); } @@ -14737,12 +14720,11 @@ public static string ProxyPATCHNamespacedService(this IKubernetes operations, st /// /// The cancellation token. /// - public static async Task ProxyPATCHNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNamespacedServiceAsync(this IKubernetes operations, string name, string namespaceParameter, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNamespacedServiceWithHttpMessagesAsync(name, namespaceParameter, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14760,7 +14742,7 @@ public static string ProxyPATCHNamespacedService(this IKubernetes operations, st /// /// path to the resource /// - public static string ProxyGETNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyGETNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyGETNamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14783,12 +14765,11 @@ public static string ProxyGETNamespacedServiceWithPath(this IKubernetes operatio /// /// The cancellation token. /// - public static async Task ProxyGETNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14806,7 +14787,7 @@ public static string ProxyGETNamespacedServiceWithPath(this IKubernetes operatio /// /// path to the resource /// - public static string ProxyPUTNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPUTNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPUTNamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14829,12 +14810,11 @@ public static string ProxyPUTNamespacedServiceWithPath(this IKubernetes operatio /// /// The cancellation token. /// - public static async Task ProxyPUTNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14852,7 +14832,7 @@ public static string ProxyPUTNamespacedServiceWithPath(this IKubernetes operatio /// /// path to the resource /// - public static string ProxyPOSTNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPOSTNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPOSTNamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14875,12 +14855,11 @@ public static string ProxyPOSTNamespacedServiceWithPath(this IKubernetes operati /// /// The cancellation token. /// - public static async Task ProxyPOSTNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14898,7 +14877,7 @@ public static string ProxyPOSTNamespacedServiceWithPath(this IKubernetes operati /// /// path to the resource /// - public static string ProxyDELETENamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyDELETENamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyDELETENamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14921,12 +14900,11 @@ public static string ProxyDELETENamespacedServiceWithPath(this IKubernetes opera /// /// The cancellation token. /// - public static async Task ProxyDELETENamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14944,7 +14922,7 @@ public static string ProxyDELETENamespacedServiceWithPath(this IKubernetes opera /// /// path to the resource /// - public static string ProxyHEADNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyHEADNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyHEADNamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -14967,12 +14945,11 @@ public static string ProxyHEADNamespacedServiceWithPath(this IKubernetes operati /// /// The cancellation token. /// - public static async Task ProxyHEADNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -14990,7 +14967,7 @@ public static string ProxyHEADNamespacedServiceWithPath(this IKubernetes operati /// /// path to the resource /// - public static string ProxyPATCHNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) + public static Stream ProxyPATCHNamespacedServiceWithPath(this IKubernetes operations, string name, string namespaceParameter, string path) { return operations.ProxyPATCHNamespacedServiceWithPathAsync(name, namespaceParameter, path).GetAwaiter().GetResult(); } @@ -15013,12 +14990,11 @@ public static string ProxyPATCHNamespacedServiceWithPath(this IKubernetes operat /// /// The cancellation token. /// - public static async Task ProxyPATCHNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNamespacedServiceWithPathAsync(this IKubernetes operations, string name, string namespaceParameter, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNamespacedServiceWithPathWithHttpMessagesAsync(name, namespaceParameter, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15030,7 +15006,7 @@ public static string ProxyPATCHNamespacedServiceWithPath(this IKubernetes operat /// /// name of the Node /// - public static string ProxyGETNode(this IKubernetes operations, string name) + public static Stream ProxyGETNode(this IKubernetes operations, string name) { return operations.ProxyGETNodeAsync(name).GetAwaiter().GetResult(); } @@ -15047,12 +15023,11 @@ public static string ProxyGETNode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyGETNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15064,7 +15039,7 @@ public static string ProxyGETNode(this IKubernetes operations, string name) /// /// name of the Node /// - public static string ProxyPUTNode(this IKubernetes operations, string name) + public static Stream ProxyPUTNode(this IKubernetes operations, string name) { return operations.ProxyPUTNodeAsync(name).GetAwaiter().GetResult(); } @@ -15081,12 +15056,11 @@ public static string ProxyPUTNode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyPUTNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15098,7 +15072,7 @@ public static string ProxyPUTNode(this IKubernetes operations, string name) /// /// name of the Node /// - public static string ProxyPOSTNode(this IKubernetes operations, string name) + public static Stream ProxyPOSTNode(this IKubernetes operations, string name) { return operations.ProxyPOSTNodeAsync(name).GetAwaiter().GetResult(); } @@ -15115,12 +15089,11 @@ public static string ProxyPOSTNode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyPOSTNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15132,7 +15105,7 @@ public static string ProxyPOSTNode(this IKubernetes operations, string name) /// /// name of the Node /// - public static string ProxyDELETENode(this IKubernetes operations, string name) + public static Stream ProxyDELETENode(this IKubernetes operations, string name) { return operations.ProxyDELETENodeAsync(name).GetAwaiter().GetResult(); } @@ -15149,12 +15122,11 @@ public static string ProxyDELETENode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyDELETENodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15166,7 +15138,7 @@ public static string ProxyDELETENode(this IKubernetes operations, string name) /// /// name of the Node /// - public static string ProxyHEADNode(this IKubernetes operations, string name) + public static Stream ProxyHEADNode(this IKubernetes operations, string name) { return operations.ProxyHEADNodeAsync(name).GetAwaiter().GetResult(); } @@ -15183,12 +15155,11 @@ public static string ProxyHEADNode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyHEADNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15200,7 +15171,7 @@ public static string ProxyHEADNode(this IKubernetes operations, string name) /// /// name of the Node /// - public static string ProxyPATCHNode(this IKubernetes operations, string name) + public static Stream ProxyPATCHNode(this IKubernetes operations, string name) { return operations.ProxyPATCHNodeAsync(name).GetAwaiter().GetResult(); } @@ -15217,12 +15188,11 @@ public static string ProxyPATCHNode(this IKubernetes operations, string name) /// /// The cancellation token. /// - public static async Task ProxyPATCHNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNodeAsync(this IKubernetes operations, string name, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNodeWithHttpMessagesAsync(name, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15237,7 +15207,7 @@ public static string ProxyPATCHNode(this IKubernetes operations, string name) /// /// path to the resource /// - public static string ProxyGETNodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyGETNodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyGETNodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15257,12 +15227,11 @@ public static string ProxyGETNodeWithPath(this IKubernetes operations, string na /// /// The cancellation token. /// - public static async Task ProxyGETNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyGETNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyGETNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyGETNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15277,7 +15246,7 @@ public static string ProxyGETNodeWithPath(this IKubernetes operations, string na /// /// path to the resource /// - public static string ProxyPUTNodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyPUTNodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyPUTNodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15297,12 +15266,11 @@ public static string ProxyPUTNodeWithPath(this IKubernetes operations, string na /// /// The cancellation token. /// - public static async Task ProxyPUTNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPUTNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPUTNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPUTNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15317,7 +15285,7 @@ public static string ProxyPUTNodeWithPath(this IKubernetes operations, string na /// /// path to the resource /// - public static string ProxyPOSTNodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyPOSTNodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyPOSTNodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15337,12 +15305,11 @@ public static string ProxyPOSTNodeWithPath(this IKubernetes operations, string n /// /// The cancellation token. /// - public static async Task ProxyPOSTNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPOSTNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPOSTNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPOSTNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15357,7 +15324,7 @@ public static string ProxyPOSTNodeWithPath(this IKubernetes operations, string n /// /// path to the resource /// - public static string ProxyDELETENodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyDELETENodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyDELETENodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15377,12 +15344,11 @@ public static string ProxyDELETENodeWithPath(this IKubernetes operations, string /// /// The cancellation token. /// - public static async Task ProxyDELETENodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyDELETENodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyDELETENodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyDELETENodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15397,7 +15363,7 @@ public static string ProxyDELETENodeWithPath(this IKubernetes operations, string /// /// path to the resource /// - public static string ProxyHEADNodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyHEADNodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyHEADNodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15417,12 +15383,11 @@ public static string ProxyHEADNodeWithPath(this IKubernetes operations, string n /// /// The cancellation token. /// - public static async Task ProxyHEADNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyHEADNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyHEADNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyHEADNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } /// @@ -15437,7 +15402,7 @@ public static string ProxyHEADNodeWithPath(this IKubernetes operations, string n /// /// path to the resource /// - public static string ProxyPATCHNodeWithPath(this IKubernetes operations, string name, string path) + public static Stream ProxyPATCHNodeWithPath(this IKubernetes operations, string name, string path) { return operations.ProxyPATCHNodeWithPathAsync(name, path).GetAwaiter().GetResult(); } @@ -15457,12 +15422,11 @@ public static string ProxyPATCHNodeWithPath(this IKubernetes operations, string /// /// The cancellation token. /// - public static async Task ProxyPATCHNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task ProxyPATCHNodeWithPathAsync(this IKubernetes operations, string name, string path, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.ProxyPATCHNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false)) - { - return _result.Body; - } + var _result = await operations.ProxyPATCHNodeWithPathWithHttpMessagesAsync(name, path, null, cancellationToken).ConfigureAwait(false); + _result.Request.Dispose(); + return _result.Body; } ///