2 instantiations of QueuedOperation
Aspire.Hosting.Azure (2)
AzureProvisioningController.cs (2)
1447var queuedOperation = new QueuedOperation( 1469return new(new QueuedOperation(model, new EnsureProvisionedIntent(), completion, cancellationToken));
8 references to QueuedOperation
Aspire.Hosting.Azure (8)
AzureProvisioningController.cs (8)
127private readonly Channel<QueuedOperation> _operationChannel = Channel.CreateUnbounded<QueuedOperation>(new UnboundedChannelOptions 1447var queuedOperation = new QueuedOperation( 1476return ProcessQueuedOperationAsync((QueuedOperation)queuedOperation.Operation); 1535await foreach (var operation in _operationChannel.Reader.ReadAllAsync(stoppingToken).ConfigureAwait(false)) 1559while (_operationChannel.Reader.TryRead(out var operation)) 1570private async Task ProcessQueuedOperationAsync(QueuedOperation queuedOperation) 1645private static void CompleteQueuedOperation(QueuedOperation queuedOperation, object? result, bool canceled, CancellationToken canceledToken, Exception? failure)