Subscribe

Eventing\DistributedApplicationEventing.cs (1)

77public DistributedApplicationEventSubscription Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent

Ats\BuilderExports.cs (2)

112return builder.Eventing.Subscribe<BeforeStartEvent>(async (@event, ct) => 133return builder.Eventing.Subscribe<AfterResourcesCreatedEvent>(async (@event, ct) =>

ContainerRegistryResourceBuilderExtensions.cs (1)

123builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>

Dashboard\DashboardEventHandlers.cs (1)

912eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)

61eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocatedAsync);

DistributedApplicationBuilder.cs (6)

322Eventing.Subscribe<BeforeStartEvent>(ExecEventingHandlers.InitializeExecResources); 518Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.InitializeDcpAnnotations); 519Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.WarnPersistentContainersWithoutUserSecrets); 523Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.MutateHttp2TransportAsync); 578Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.ExcludeDashboardFromManifestAsync); 583Eventing.Subscribe<BeforeStartEvent>((e, ct) => BuiltInDistributedApplicationEventSubscriptionHandlers.UpdateContainerRegistryAsync(e, options));

Eventing\DistributedApplicationEventing.cs (2)

76/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 105/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" />

Lifecycle\RequiredCommandValidationLifecycleHook.cs (1)

27eventing.Subscribe<BeforeResourceStartedEvent>(ValidateRequiredCommandsAsync);

Orchestrator\ApplicationOrchestrator.cs (3)

73_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated); 74_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 76_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent);

PublisherDistributedApplicationBuilderExtensions.cs (1)

30builder.Eventing.Subscribe<PublisherAdvertisementEvent>((e, ct) => {

ResourceBuilderExtensions.cs (1)

2742builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) =>

AzureResourcePreparer.cs (1)

448eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

Provisioning\Provisioners\AzureProvisioner.cs (1)

284eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

AzureContainerAppsInfrastructure.cs (1)

90eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

AzureAppServiceInfrastructure.cs (1)

90eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

AzureContainerRegistryExtensions.cs (1)

84builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>

AzureCosmosDBExtensions.cs (1)

487builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, _) =>

AzureFunctionsProjectResourceExtensions.cs (1)

157builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>

AzurePostgresExtensions.cs (1)

309builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>

AzureManagedRedisExtensions.cs (1)

141builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>

AzureRedisExtensions.cs (1)

209builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>

AzureSqlServerResource.cs (1)

504builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>

DockerComposeInfrastructure.cs (1)

129eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

JavaScriptHostingExtensions.cs (3)

269builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 474builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 1142resource.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>

KubernetesInfrastructure.cs (1)

73eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)

25eventing.Subscribe<AfterResourcesCreatedEvent>(async (@event, ct) =>

MauiOtlpExtensions.cs (1)

119appBuilder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) =>

Utilities\MauiAndroidEnvironmentAnnotation.cs (1)

49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);

Utilities\MauiiOSEnvironmentAnnotation.cs (1)

49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);

PythonAppResourceBuilderExtensions.cs (2)

494builder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) => 1335builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>

Backchannel\AppHostBackchannelTests.cs (3)

24builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 30builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 68builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {

Backchannel\AuxiliaryBackchannelTests.cs (2)

27builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 64builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>

Cli\CliOrphanDetectorTests.cs (1)

245builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>

DistributedApplicationTests.cs (2)

266testProgram.AppBuilder.Eventing.Subscribe<AfterResourcesCreatedEvent>((_, _) => 1066events.Subscribe<BeforeResourceStartedEvent>(async (e, ct) =>

Eventing\DistributedApplicationBuilderEventingTests.cs (12)

OperationModesTests.cs (4)

24builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 53builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 82builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 113builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {