115 instantiations of BeforeResourceStartedEvent
Aspire.Hosting (3)
ConnectionStringBuilderExtensions.cs (1)
93await @evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(r, @evt.Services), ct).ConfigureAwait(false);
ExternalServiceBuilderExtensions.cs (1)
168await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(e.Resource, e.Services), ct).ConfigureAwait(false);
Orchestrator\ApplicationOrchestrator.cs (1)
279var beforeResourceStartedEvent = new BeforeResourceStartedEvent(context.Resource, _serviceProvider)
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
3917var beforeResourceStartedEvent = new BeforeResourceStartedEvent(resource.Resource, serviceProvider);
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
226await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false); 743await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, services), EventDispatchBehavior.NonBlockingSequential, ct).ConfigureAwait(false);
Aspire.Hosting.DevTunnels.Tests (2)
DevTunnelResourceBuilderExtensionsTests.cs (2)
225await builder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnel.Resource, app.Services)).DefaultTimeout(); 265await builder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnel.Resource, app.Services)).DefaultTimeout();
Aspire.Hosting.Dotnet.Tests (8)
DotnetProjectBuildCoordinatorTests.cs (8)
897new BeforeResourceStartedEvent(buildResource, app.Services), 914new BeforeResourceStartedEvent(buildResource, app.Services), 1121new BeforeResourceStartedEvent(buildResource, app.Services), 1169new BeforeResourceStartedEvent(rebuilder, app.Services), 1238new BeforeResourceStartedEvent(buildResource, app.Services), 1248new BeforeResourceStartedEvent(rebuilder, app.Services), 1374new BeforeResourceStartedEvent(buildResource, app.Services), 1397new BeforeResourceStartedEvent(rebuilder, app.Services),
Aspire.Hosting.Java.Tests (16)
AddJavaAppTests.cs (4)
747new BeforeResourceStartedEvent(app.Resource, built.Services), 766new BeforeResourceStartedEvent(app.Resource, built.Services), 793new BeforeResourceStartedEvent(app.Resource, built.Services), 854new BeforeResourceStartedEvent(app.Resource, built.Services),
AddQuarkusAppTests.cs (3)
97new BeforeResourceStartedEvent(app.Resource, application.Services), 114new BeforeResourceStartedEvent(app.Resource, application.Services), 286new BeforeResourceStartedEvent(app.Resource, application.Services),
AddSpringBootAppTests.cs (9)
22new BeforeResourceStartedEvent(app.Resource, application.Services), 39new BeforeResourceStartedEvent(app.Resource, application.Services), 56new BeforeResourceStartedEvent(app.Resource, application.Services), 76new BeforeResourceStartedEvent(runApp.Resource, application.Services), 114new BeforeResourceStartedEvent(app.Resource, application.Services), 137new BeforeResourceStartedEvent(app.Resource, application.Services), 190new BeforeResourceStartedEvent(app.Resource, application.Services), 211new BeforeResourceStartedEvent(runApp.Resource, application.Services), 238new BeforeResourceStartedEvent(app.Resource, application.Services),
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
218new BeforeResourceStartedEvent(kafkaUiResource, app.Services),
Aspire.Hosting.Maui.Tests (52)
MauiBuildQueueTests.cs (38)
56new BeforeResourceStartedEvent(env.Android, env.Services), 76new BeforeResourceStartedEvent(env.Android, env.Services), 89new BeforeResourceStartedEvent(env.Android, env.Services), 96new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 117new BeforeResourceStartedEvent(env.Android, env.Services), 138new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 172new BeforeResourceStartedEvent(env.Android, env.Services), 189new BeforeResourceStartedEvent(env.Android, env.Services), 193new BeforeResourceStartedEvent(env.Android2!, env.Services), 220new BeforeResourceStartedEvent(env.Android, env.Services), 234new BeforeResourceStartedEvent(env.Android, env.Services), 242new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 257new BeforeResourceStartedEvent(env.IOSSimulator, env.Services), 271new BeforeResourceStartedEvent(env.Android, env.Services), 284new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 292new BeforeResourceStartedEvent(env.IOSSimulator, env.Services), 350new BeforeResourceStartedEvent(env.Android, env.Services), 357new BeforeResourceStartedEvent(env.Parent, env.Services), 374new BeforeResourceStartedEvent(env.Android, env.Services), 384new BeforeResourceStartedEvent(env.Android, env.Services), 415new BeforeResourceStartedEvent(android, app.Services), 453new BeforeResourceStartedEvent(android, app.Services), 474new BeforeResourceStartedEvent(env.Android, env.Services), 521new BeforeResourceStartedEvent(env.Android, env.Services), 529new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 560new BeforeResourceStartedEvent(env.Android, env.Services), 595new BeforeResourceStartedEvent(env.Android, env.Services), 617new BeforeResourceStartedEvent(env.Android, env.Services), 694new BeforeResourceStartedEvent(env.Android, env.Services), 697new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 848new BeforeResourceStartedEvent(env.Android, env.Services), 865new BeforeResourceStartedEvent(env.Android, env.Services), 936new BeforeResourceStartedEvent(env.Android, env.Services), 955new BeforeResourceStartedEvent(env.Android, env.Services), 1043new BeforeResourceStartedEvent(env.Android, env.Services), 1053new BeforeResourceStartedEvent(env.MacCatalyst, env.Services), 1057new BeforeResourceStartedEvent(env.IOSSimulator, env.Services), 1100new BeforeResourceStartedEvent(env.Android, env.Services),
MauiiOSValidationTests.cs (6)
35.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None); 60.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None); 84.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None); 104.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None); 122.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None); 140.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None);
MauiPlatformExtensionsTests.cs (8)
296.PublishAsync(new BeforeResourceStartedEvent(platform.Resource, app.Services), CancellationToken.None); 593await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services), CancellationToken.None); 1118appBuilder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services), CancellationToken.None)); 1144appBuilder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services), CancellationToken.None)); 1174new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services), 1225new BeforeResourceStartedEvent(resolutionEventResource, app.Services), 1249new BeforeResourceStartedEvent(resolutionEventResource, app.Services), 1341new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services),
Aspire.Hosting.MongoDB (1)
ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (1)
134await evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, evt.Services), ct)
Aspire.Hosting.MongoDB.Tests (1)
ReplicaSet\AddMongoDBReplicaSetTests.cs (1)
327await eventing.PublishAsync(new BeforeResourceStartedEvent(mongo1.Resource, app.Services));
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)
561await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 587await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 608await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services));
Aspire.Hosting.Tests (19)
Orchestrator\ApplicationOrchestratorTests.cs (1)
1095await @event.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, @event.Services), ct);
RequiredCommandAnnotationTests.cs (17)
156await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 173await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 191await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 214await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 241await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 267await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 288await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 309await eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 310await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services)); 340await eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 341await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services)); 375await eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 376await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services)); 400var publishTask = eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 431await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services)); 458var publishTask1 = eventing.PublishAsync(new BeforeResourceStartedEvent(resource1, app.Services)); 464await eventing.PublishAsync(new BeforeResourceStartedEvent(resource2, app.Services));
WithUrlsTests.cs (1)
568await 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);
38 references to BeforeResourceStartedEvent
Aspire.Hosting (10)
Ats\EventingExports.cs (1)
72internal static IResourceBuilder<T> OnBeforeResourceStarted<T>(this IResourceBuilder<T> builder, Func<BeforeResourceStartedEvent, Task> callback)
Dashboard\DashboardEventHandlers.cs (1)
379eventing.Subscribe<BeforeResourceStartedEvent>(dashboardResource, (@event, _) =>
DistributedApplicationEventingExtensions.cs (2)
52/// Subscribes a callback to the <see cref="BeforeResourceStartedEvent"/> event within the AppHost. 60public static IResourceBuilder<T> OnBeforeResourceStarted<T>(this IResourceBuilder<T> builder, Func<T, BeforeResourceStartedEvent, CancellationToken, Task> callback)
DotnetToolResourceExtensions.cs (1)
100async Task BeforeResourceStarted(T resource, BeforeResourceStartedEvent evt, CancellationToken ct)
Lifecycle\RequiredCommandValidationEventingSubscriber.cs (2)
27eventing.Subscribe<BeforeResourceStartedEvent>(ValidateRequiredCommandsAsync); 31private async Task ValidateRequiredCommandsAsync(BeforeResourceStartedEvent @event, CancellationToken cancellationToken)
Orchestrator\ApplicationOrchestrator.cs (3)
79_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent); 116private async Task WaitForInBeforeResourceStartedEvent(BeforeResourceStartedEvent @event, CancellationToken cancellationToken) 279var beforeResourceStartedEvent = new BeforeResourceStartedEvent(context.Resource, _serviceProvider)
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
3917var beforeResourceStartedEvent = new BeforeResourceStartedEvent(resource.Resource, serviceProvider);
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
226await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false); 743await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, services), EventDispatchBehavior.NonBlockingSequential, ct).ConfigureAwait(false);
Aspire.Hosting.Dotnet (3)
DotnetProjectBuildCoordinator.cs (3)
135var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>( 161var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>( 680var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>(
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
118builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(kafkaUi, (e, ct) =>
Aspire.Hosting.Maui (7)
Lifecycle\MauiBuildQueueEventSubscriber.cs (2)
58eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync); 62private async Task OnBeforeResourceStartedAsync(BeforeResourceStartedEvent @event, CancellationToken cancellationToken)
MauiOtlpExtensions.cs (1)
127appBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(async (evt, ct) =>
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)
263builder.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)
250builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(resource, async (e, ct) =>
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
561await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 587await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 608await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services));
Aspire.Hosting.Tests (7)
DistributedApplicationTests.cs (2)
1213var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>(); 1214events.Subscribe<BeforeResourceStartedEvent>(async (e, ct) =>
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
211builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) =>
Orchestrator\ApplicationOrchestratorTests.cs (4)
431applicationEventing.Subscribe<BeforeResourceStartedEvent>(resource.Resource, (_, _) => 433observedEvents.Add(nameof(BeforeResourceStartedEvent)); 446eventName => Assert.Equal(nameof(BeforeResourceStartedEvent), eventName)); 1080/// <see cref="KnownResourceStates.NotStarted"/> and publishes <see cref="BeforeResourceStartedEvent"/> itself