4 instantiations of RpcResourceState
Aspire.Cli.Tests (4)
Commands\RunCommandTests.cs (2)
2746yield return new RpcResourceState 2754yield 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)
601await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 1432private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 1434public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 1436if (_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)
2742static 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)