2 instantiations of RpcResourceState
Aspire.Cli.Tests (2)
TestServices\TestAppHostBackchannel.cs (2)
81yield return new RpcResourceState 89yield return new RpcResourceState
14 references to RpcResourceState
aspire (10)
Backchannel\AppHostBackchannel.cs (4)
20IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(CancellationToken cancellationToken); 103public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 111var resourceStates = await rpc.InvokeWithCancellationAsync<IAsyncEnumerable<RpcResourceState>>( 118await 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)
201await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 325private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 327public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 329if (_resourceStates.TryGetValue(resourceState.Resource, out var existingResourceState))
Aspire.Cli.Tests (4)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
634public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
TestServices\TestAppHostBackchannel.cs (3)
21public Func<CancellationToken, IAsyncEnumerable<RpcResourceState>>? GetResourceStatesAsyncCallback { get; set; } 64public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 71await foreach (var resourceState in resourceStates)