2 instantiations of RpcResourceState
Aspire.Cli.Tests (2)
TestServices\TestAppHostBackchannel.cs (2)
80yield return new RpcResourceState 88yield return new RpcResourceState
14 references to RpcResourceState
aspire (10)
Backchannel\AppHostBackchannel.cs (4)
20IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(CancellationToken cancellationToken); 85public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 92var resourceStates = await rpc.InvokeWithCancellationAsync<IAsyncEnumerable<RpcResourceState>>( 99await foreach (var state in resourceStates.WithCancellation(cancellationToken))
Backchannel\BackchannelJsonSerializerContext.cs (2)
18[JsonSerializable(typeof(IAsyncEnumerable<RpcResourceState>))] 19[JsonSerializable(typeof(MessageFormatterEnumerableTracker.EnumeratorResults<RpcResourceState>))]
Commands\RunCommand.cs (4)
239await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 400private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 402public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 404if (_resourceStates.TryGetValue(resourceState.Resource, out var existingResourceState))
Aspire.Cli.Tests (4)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
639public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
TestServices\TestAppHostBackchannel.cs (3)
19public Func<CancellationToken, IAsyncEnumerable<RpcResourceState>>? GetResourceStatesAsyncCallback { get; set; } 63public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 70await foreach (var resourceState in resourceStates)