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