2 instantiations of QueuedOperation
Aspire.Hosting.Azure (2)
AzureProvisioningController.cs (2)
1402var queuedOperation = new QueuedOperation( 1424return new(new QueuedOperation(model, new EnsureProvisionedIntent(), completion, cancellationToken));
8 references to QueuedOperation
Aspire.Hosting.Azure (8)
AzureProvisioningController.cs (8)
128private readonly Channel<QueuedOperation> _operationChannel = Channel.CreateUnbounded<QueuedOperation>(new UnboundedChannelOptions 1402var queuedOperation = new QueuedOperation( 1431return ProcessQueuedOperationAsync((QueuedOperation)queuedOperation.Operation); 1490await foreach (var operation in _operationChannel.Reader.ReadAllAsync(stoppingToken).ConfigureAwait(false)) 1514while (_operationChannel.Reader.TryRead(out var operation)) 1525private async Task ProcessQueuedOperationAsync(QueuedOperation queuedOperation) 1600private static void CompleteQueuedOperation(QueuedOperation queuedOperation, object? result, bool canceled, CancellationToken canceledToken, Exception? failure)