4 instantiations of RpcResourceState
Aspire.Cli.Tests (4)
Commands\RunCommandTests.cs (2)
2700yield return new RpcResourceState 2708yield 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)
27[JsonSerializable(typeof(IAsyncEnumerable<RpcResourceState>))] 28[JsonSerializable(typeof(MessageFormatterEnumerableTracker.EnumeratorResults<RpcResourceState>))]
Commands\RunCommand.cs (4)
593await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 1424private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 1426public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 1428if (_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)
2696static 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)