4 instantiations of RpcResourceState
Aspire.Cli.Tests (4)
Commands\RunCommandTests.cs (2)
2757yield return new RpcResourceState 2765yield return new RpcResourceState
TestServices\TestAppHostCliBackchannel.cs (2)
87yield return new RpcResourceState 95yield return new RpcResourceState
15 references to RpcResourceState
aspire (10)
Backchannel\AppHostCliBackchannel.cs (4)
21IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(CancellationToken cancellationToken); 140public IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(CancellationToken cancellationToken) 142return InvokeStreamingRpcAsync<RpcResourceState>( 143(rpc, ct) => rpc.InvokeStreamingWithProfilingAsync<RpcResourceState>(
Backchannel\BackchannelJsonSerializerContext.cs (2)
28[JsonSerializable(typeof(IAsyncEnumerable<RpcResourceState>))] 29[JsonSerializable(typeof(MessageFormatterEnumerableTracker.EnumeratorResults<RpcResourceState>))]
Commands\RunCommand.cs (4)
603await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 1434private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 1436public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 1438if (_resourceStates.TryGetValue(resourceState.Resource, out var existingResourceState))
Aspire.Cli.Tests (5)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
1110public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
Commands\RunCommandTests.cs (1)
2753static async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(
TestServices\TestAppHostCliBackchannel.cs (3)
19public Func<CancellationToken, IAsyncEnumerable<RpcResourceState>>? GetResourceStatesAsyncCallback { get; set; } 70public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 77await foreach (var resourceState in resourceStates)