1 implementation of Subscribe
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
77
public DistributedApplicationEventSubscription
Subscribe
<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent
38 references to Subscribe
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
221
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
Aspire.Hosting (13)
DistributedApplicationBuilder.cs (5)
235
Eventing.
Subscribe
<BeforeStartEvent>(ExecEventingHandlers.InitializeExecResources);
385
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.InitializeDcpAnnotations);
389
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.MutateHttp2TransportAsync);
398
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.ExcludeDashboardFromManifestAsync);
403
Eventing.
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})" />
Orchestrator\ApplicationOrchestrator.cs (4)
58
_eventing.
Subscribe
<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated);
59
_eventing.
Subscribe
<ConnectionStringAvailableEvent>(PublishConnectionStringValue);
61
_eventing.
Subscribe
<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent);
62
_eventing.
Subscribe
<InitializeResourceEvent>(OnResourceInitialized);
PublisherDistributedApplicationBuilderExtensions.cs (1)
29
builder.Eventing.
Subscribe
<PublisherAdvertisementEvent>((e, ct) => {
ResourceBuilderExtensions.cs (1)
1789
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) =>
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
400
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, _) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
63
builder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.PostgreSQL (1)
AzurePostgresExtensions.cs (1)
300
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.Redis (1)
AzureRedisExtensions.cs (1)
206
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Tests (20)
Backchannel\AppHostBackchannelTests.cs (3)
24
builder.Eventing.
Subscribe
<BackchannelReadyEvent>((e, ct) => {
30
builder.Eventing.
Subscribe
<BackchannelConnectedEvent>((e, ct) => {
68
builder.Eventing.
Subscribe
<BackchannelReadyEvent>((e, ct) => {
DistributedApplicationTests.cs (1)
619
events.
Subscribe
<BeforeResourceStartedEvent>(async (e, ct) =>
Eventing\DistributedApplicationBuilderEventingTests.cs (12)
23
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
30
builder.Eventing.
Subscribe
<DummyEvent>((@event, ct) =>
55
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
62
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
87
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
94
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
120
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
129
builder.Eventing.
Subscribe
<DummyEvent>((@event, ct) =>
207
builder.Eventing.
Subscribe
<BeforeResourceStartedEvent>((e, ct) =>
232
builder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) =>
240
builder.Eventing.
Subscribe
<AfterEndpointsAllocatedEvent>((e, ct) =>
248
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) =>
OperationModesTests.cs (4)
23
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
52
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
81
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
112
builder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) => {