1 write to _cts
Aspire.Cli.Tests (1)
Commands\AgentMcpCommandTests.cs (1)
39_cts = new CancellationTokenSource();
19 references to _cts
Aspire.Cli.Tests (19)
Commands\AgentMcpCommandTests.cs (19)
72await _agentMcpCommand.ExecuteCommandAsync(parseResult, _cts.Token); 78}, _cts.Token); 81_mcpClient = await _testTransport.CreateClientAsync(_loggerFactory, _cts.Token); 91await _cts.CancelAsync(); 116_cts?.Dispose(); 123var tools = await _mcpClient.ListToolsAsync(cancellationToken: _cts.Token).DefaultTimeout(); 197await _mcpClient.CallToolAsync(KnownMcpTools.RefreshTools, cancellationToken: _cts.Token).DefaultTimeout(); 200var tools = await _mcpClient.ListToolsAsync(cancellationToken: _cts.Token).DefaultTimeout(); 272await _mcpClient.CallToolAsync(KnownMcpTools.RefreshTools, cancellationToken: _cts.Token).DefaultTimeout(); 277cancellationToken: _cts.Token).DefaultTimeout(); 345await _mcpClient.CallToolAsync(KnownMcpTools.RefreshTools, cancellationToken: _cts.Token).DefaultTimeout(); 348var result = await _mcpClient.CallToolAsync("db1_mcp_list_schemas", cancellationToken: _cts.Token).DefaultTimeout(); 363cancellationToken: _cts.Token).DefaultTimeout(); 392cancellationToken: _cts.Token).DefaultTimeout(); 408var notification = await notificationChannel.Reader.ReadAsync(_cts.Token).AsTask().DefaultTimeout(); 466var tools = await _mcpClient.ListToolsAsync(cancellationToken: _cts.Token).DefaultTimeout(); 544var tools1 = await _mcpClient.ListToolsAsync(cancellationToken: _cts.Token).DefaultTimeout(); 545var tools2 = await _mcpClient.ListToolsAsync(cancellationToken: _cts.Token).DefaultTimeout(); 566cancellationToken: _cts.Token).DefaultTimeout());