1 write to _cts
Aspire.Cli.Tests (1)
Commands\AgentMcpCommandTests.cs (1)
39
_cts
= new CancellationTokenSource();
14 references to _cts
Aspire.Cli.Tests (14)
Commands\AgentMcpCommandTests.cs (14)
72
await _agentMcpCommand.ExecuteCommandAsync(parseResult,
_cts
.Token);
78
},
_cts
.Token);
81
_mcpClient = await _testTransport.CreateClientAsync(_loggerFactory,
_cts
.Token);
91
await
_cts
.CancelAsync();
116
_cts
?.Dispose();
123
var tools = await _mcpClient.ListToolsAsync(cancellationToken:
_cts
.Token).DefaultTimeout();
197
await _mcpClient.CallToolAsync(KnownMcpTools.RefreshTools, cancellationToken:
_cts
.Token).DefaultTimeout();
200
var tools = await _mcpClient.ListToolsAsync(cancellationToken:
_cts
.Token).DefaultTimeout();
272
await _mcpClient.CallToolAsync(KnownMcpTools.RefreshTools, cancellationToken:
_cts
.Token).DefaultTimeout();
277
cancellationToken:
_cts
.Token).DefaultTimeout();
300
cancellationToken:
_cts
.Token).DefaultTimeout();
329
cancellationToken:
_cts
.Token).DefaultTimeout();
345
var notification = await notificationChannel.Reader.ReadAsync(
_cts
.Token).AsTask().DefaultTimeout();
357
cancellationToken:
_cts
.Token).DefaultTimeout());