2 instantiations of RpcResourceState
Aspire.Cli.Tests (2)
TestServices\TestAppHostCliBackchannel.cs (2)
87yield return new RpcResourceState 95yield return new RpcResourceState
14 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)
530await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 1320private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 1322public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 1324if (_resourceStates.TryGetValue(resourceState.Resource, out var existingResourceState))
Aspire.Cli.Tests (4)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
1110public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
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)