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)

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

Dashboard\DashboardEventHandlers.cs (1)

884eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)

61eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocatedAsync);

DistributedApplicationBuilder.cs (5)

306Eventing.Subscribe<BeforeStartEvent>(ExecEventingHandlers.InitializeExecResources); 498Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.InitializeDcpAnnotations); 502Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.MutateHttp2TransportAsync); 557Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.ExcludeDashboardFromManifestAsync); 562Eventing.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) => {

AzureResourcePreparer.cs (1)

439eventing.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)

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

AzureCosmosDBExtensions.cs (1)

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

AzureFunctionsProjectResourceExtensions.cs (1)

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

AzurePostgresExtensions.cs (1)

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

AzureManagedRedisExtensions.cs (1)

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

AzureRedisExtensions.cs (1)

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

DockerComposeInfrastructure.cs (1)

129eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

JavaScriptHostingExtensions.cs (4)

263builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 466builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 634builder.Eventing.Subscribe<BeforeStartEvent>((@event, _) => 988resource.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>

KeycloakResourceBuilderExtensions.cs (1)

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

KubernetesInfrastructure.cs (1)

73eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);

Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)

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

MauiOtlpExtensions.cs (1)

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

Utilities\MauiAndroidEnvironmentAnnotation.cs (1)

49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);

Utilities\MauiiOSEnvironmentAnnotation.cs (1)

49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);

PythonAppResourceBuilderExtensions.cs (3)

315builder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) => 513builder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) => 1349builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>

RedisBuilderExtensions.cs (2)

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

Backchannel\AppHostBackchannelTests.cs (3)

23builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 29builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 67builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {

Backchannel\AuxiliaryBackchannelTests.cs (2)

25builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 65builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>

Cli\CliOrphanDetectorTests.cs (1)

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

DistributedApplicationTests.cs (2)

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

Eventing\DistributedApplicationBuilderEventingTests.cs (12)

OperationModesTests.cs (4)

23builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 52builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 81builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 112builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {