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