kubernetes-client/csharp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dispose cts after call finish (#1128)

Browse Source
This commit is contained in:
Boshi Lian
2022-12-13 14:17:34 -08:00
committed by GitHub
parent 5d98bcca13
commit 7d1341d016
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/LibKubernetesGenerator/templates/Operations.cs.template
View File

@@ -7,7 +7,7 @@
namespace k8s; namespace k8s;
public partial class AbstractKubernetes : I{{name}}Operations public partial class AbstractKubernetes : I{{name}}Operations
{ {
{{#apis}} {{#apis}}
/// <inheritdoc/> /// <inheritdoc/>
async Task<HttpOperationResponse{{GetReturnType operation "<>"}}> I{{name}}Operations.{{GetMethodName operation "WithHttpMessagesAsync"}}( async Task<HttpOperationResponse{{GetReturnType operation "<>"}}> I{{name}}Operations.{{GetMethodName operation "WithHttpMessagesAsync"}}(
@@ -17,7 +17,7 @@ public partial class AbstractKubernetes : I{{name}}Operations
IReadOnlyDictionary<string, IReadOnlyList<string>> customHeaders, IReadOnlyDictionary<string, IReadOnlyList<string>> customHeaders,
CancellationToken cancellationToken) CancellationToken cancellationToken)
{ {
var cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken); using var cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
cts.CancelAfter(HttpClientTimeout); cts.CancelAfter(HttpClientTimeout);
{{#IfParamContains operation "watch"}} {{#IfParamContains operation "watch"}}
if (watch == true) if (watch == true)
@@ -58,13 +58,13 @@ public partial class AbstractKubernetes : I{{name}}Operations
{{#IfParamDoesNotContain operation "body"}} {{#IfParamDoesNotContain operation "body"}}
var httpResponse = await SendRequest<object>(url, HttpMethods.{{Method}}, customHeaders, null, cancellationToken); var httpResponse = await SendRequest<object>(url, HttpMethods.{{Method}}, customHeaders, null, cancellationToken);
{{/IfParamDoesNotContain operation "body"}} {{/IfParamDoesNotContain operation "body"}}
// Create Result // Create Result
var httpRequest = httpResponse.RequestMessage; var httpRequest = httpResponse.RequestMessage;
{{#IfReturnType operation "void"}} {{#IfReturnType operation "void"}}
HttpOperationResponse result = new HttpOperationResponse() { Request = httpRequest, Response = httpResponse }; HttpOperationResponse result = new HttpOperationResponse() { Request = httpRequest, Response = httpResponse };
{{/IfReturnType operation "void"}} {{/IfReturnType operation "void"}}
{{#IfReturnType operation "obj"}} {{#IfReturnType operation "obj"}}
var result = await CreateResultAsync{{GetReturnType operation "<>"}}( var result = await CreateResultAsync{{GetReturnType operation "<>"}}(
httpRequest, httpRequest,
httpResponse, httpResponse,
{{#IfParamContains operation "watch"}} {{#IfParamContains operation "watch"}}