17 references to Token
Aspire.Hosting.Native.Core (6)
Runtime\ResourceWorkload.cs (6)
265
preparation = await allocator.PrepareAsync(identity, allocationTemplate, allocation.
Token
).ConfigureAwait(false);
272
await waitForValues(values.
Token
).ConfigureAwait(false);
278
await initialize(startup.
Token
).ConfigureAwait(false);
284
await preparation.StartAsync(plan, startup.
Token
).ConfigureAwait(false);
289
lease = await executor.StartAsync(identity, plan, startup.
Token
).ConfigureAwait(false);
293
await allocated(lease.Endpoint, startup.
Token
).ConfigureAwait(false);
Aspire.Hosting.Native.Server (11)
Dashboard\DcpDashboard.cs (1)
69
using var response = await http.GetAsync(new Uri(frontend, "health"), requestTimeout.
Token
).ConfigureAwait(false);
Dcp\DcpApiClient.cs (6)
147
using var response = await Client.GetAsync(path, HttpCompletionOption.ResponseHeadersRead, timeout.
Token
).ConfigureAwait(false);
152
using var input = new DcpResponseStream(await response.Content.ReadAsStreamAsync(timeout.
Token
).ConfigureAwait(false), 65536);
160
var length = await reader.ReadBlockAsync(text.AsMemory(0, 65537), timeout.
Token
).ConfigureAwait(false);
182
using var response = await Client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, timeout.
Token
).ConfigureAwait(false);
196
using var input = new DcpResponseStream(await response.Content.ReadAsStreamAsync(timeout.
Token
).ConfigureAwait(false), 1024 * 1024);
198
return await JsonSerializer.DeserializeAsync(input, responseType, timeout.
Token
).ConfigureAwait(false);
NativeServerHostedService.cs (2)
162
await dcp.StartAsync(dcpExecutable, startup.
Token
).ConfigureAwait(false);
171
settings.DashboardCredentials, options, startup.
Token
).ConfigureAwait(false);
Rpc\NativeBackchannelRpc.cs (1)
26
using var lifetime = CancellationTokenSource.CreateLinkedTokenSource(firstRequest.
Token
);
Rpc\NativeRpcListener.cs (1)
205
}, lifetime.
Token
).ConfigureAwait(false);