33 instantiations of BeforeResourceStartedEvent
Aspire.Hosting (3)
ConnectionStringBuilderExtensions.cs (1)
93await @evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(r, @evt.Services), ct).ConfigureAwait(false);
ExternalServiceBuilderExtensions.cs (1)
147await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(e.Resource, e.Services), ct).ConfigureAwait(false);
Orchestrator\ApplicationOrchestrator.cs (1)
198var beforeResourceStartedEvent = new BeforeResourceStartedEvent(context.Resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
189var beforeResourceStartedEvent = new BeforeResourceStartedEvent(resource.Resource, serviceProvider);
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
222await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false); 688await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, services), EventDispatchBehavior.NonBlockingSequential, ct).ConfigureAwait(false);
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
218new BeforeResourceStartedEvent(kafkaUiResource, app.Services),
Aspire.Hosting.Maui.Tests (1)
MauiPlatformExtensionsTests.cs (1)
250.PublishAsync(new BeforeResourceStartedEvent(platform.Resource, app.Services), CancellationToken.None);
Aspire.Hosting.MySql.Tests (3)
AddMySqlTests.cs (3)
244await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services)); 275builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services)); 385new BeforeResourceStartedEvent(phpMyAdminResource, app.Services),
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
489await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 515await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 536await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services));
Aspire.Hosting.Tests (16)
RequiredCommandAnnotationTests.cs (15)
157await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 174await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 192await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 215await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 242await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 268await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 289await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 310await eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 311await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services)); 343await eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 344await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services)); 368var publishTask = eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 399await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 426var publishTask1 = eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 432await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services));
WithUrlsTests.cs (1)
569await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(custom, e.Services), EventDispatchBehavior.BlockingSequential, ct);
CustomResources.AppHost (3)
TalkingClockResource.cs (3)
66await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, services), token); 67await eventing.PublishAsync(new BeforeResourceStartedEvent(resource.TickHand, services), token); 68await eventing.PublishAsync(new BeforeResourceStartedEvent(resource.TockHand, services), token);
27 references to BeforeResourceStartedEvent
Aspire.Hosting (9)
Ats\EventingExports.cs (1)
35internal static IResourceBuilder<T> OnBeforeResourceStarted<T>(this IResourceBuilder<T> builder, Func<BeforeResourceStartedEvent, Task> callback)
DistributedApplicationEventingExtensions.cs (2)
15/// Subscribes a callback to the <see cref="BeforeResourceStartedEvent"/> event within the AppHost. 23public static IResourceBuilder<T> OnBeforeResourceStarted<T>(this IResourceBuilder<T> builder, Func<T, BeforeResourceStartedEvent, CancellationToken, Task> callback)
DotnetToolResourceExtensions.cs (1)
96async Task BeforeResourceStarted(T resource, BeforeResourceStartedEvent evt, CancellationToken ct)
Lifecycle\RequiredCommandValidationLifecycleHook.cs (2)
27eventing.Subscribe<BeforeResourceStartedEvent>(ValidateRequiredCommandsAsync); 31private async Task ValidateRequiredCommandsAsync(BeforeResourceStartedEvent @event, CancellationToken cancellationToken)
Orchestrator\ApplicationOrchestrator.cs (3)
76_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent); 93private async Task WaitForInBeforeResourceStartedEvent(BeforeResourceStartedEvent @event, CancellationToken cancellationToken) 198var beforeResourceStartedEvent = new BeforeResourceStartedEvent(context.Resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
189var beforeResourceStartedEvent = new BeforeResourceStartedEvent(resource.Resource, serviceProvider);
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
222await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false); 688await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, services), EventDispatchBehavior.NonBlockingSequential, ct).ConfigureAwait(false);
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
114builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(kafkaUi, (e, ct) =>
Aspire.Hosting.Maui (4)
Utilities\MauiAndroidEnvironmentAnnotation.cs (2)
49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync); 53private async Task OnBeforeResourceStartedAsync(BeforeResourceStartedEvent @event, CancellationToken cancellationToken)
Utilities\MauiiOSEnvironmentAnnotation.cs (2)
49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync); 53private async Task OnBeforeResourceStartedAsync(BeforeResourceStartedEvent @event, CancellationToken cancellationToken)
Aspire.Hosting.MySql (1)
MySqlBuilderExtensions.cs (1)
245builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(phpMyAdminContainer, async (e, ct) =>
Aspire.Hosting.MySql.Tests (2)
AddMySqlTests.cs (2)
244await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services)); 275builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services));
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
234builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(resource, async (e, ct) =>
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
489await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 515await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 536await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services));
Aspire.Hosting.Tests (3)
DistributedApplicationTests.cs (2)
1065var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>(); 1066events.Subscribe<BeforeResourceStartedEvent>(async (e, ct) =>
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
208builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) =>