2 instantiations of RpcResourceState
Aspire.Cli.Tests (2)
TestServices\TestAppHostCliBackchannel.cs (2)
76yield return new RpcResourceState 84yield return new RpcResourceState
15 references to RpcResourceState
aspire (11)
Backchannel\AppHostCliBackchannel.cs (5)
19IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync(CancellationToken cancellationToken); 117public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 121IAsyncEnumerable<RpcResourceState>? resourceStates = null; 129resourceStates = await rpc.InvokeWithCancellationAsync<IAsyncEnumerable<RpcResourceState>>( 145await foreach (var state in EnumerateWithReconnect(resourceStates, cancellationToken))
Backchannel\BackchannelJsonSerializerContext.cs (2)
25[JsonSerializable(typeof(IAsyncEnumerable<RpcResourceState>))] 26[JsonSerializable(typeof(MessageFormatterEnumerableTracker.EnumeratorResults<RpcResourceState>))]
Commands\RunCommand.cs (4)
300await foreach (var resourceState in resourceStates.WithCancellation(cancellationToken)) 553private readonly Dictionary<string, RpcResourceState> _resourceStates = new(); 555public void ProcessResourceState(RpcResourceState resourceState, Action<string, string> endpointWriter) 557if (_resourceStates.TryGetValue(resourceState.Resource, out var existingResourceState))
Aspire.Cli.Tests (4)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
826public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
TestServices\TestAppHostCliBackchannel.cs (3)
18public Func<CancellationToken, IAsyncEnumerable<RpcResourceState>>? GetResourceStatesAsyncCallback { get; set; } 59public async IAsyncEnumerable<RpcResourceState> GetResourceStatesAsync([EnumeratorCancellation]CancellationToken cancellationToken) 66await foreach (var resourceState in resourceStates)