45 references to Subscribe
Aspire.Hosting (6)
Orchestrator\ApplicationOrchestrator.cs (6)
69dcpExecutorEvents.Subscribe<OnResourcesPreparedContext>(OnResourcesPrepared); 70dcpExecutorEvents.Subscribe<OnResourceChangedContext>(OnResourceChanged); 71dcpExecutorEvents.Subscribe<OnEndpointsAllocatedContext>(OnEndpointsAllocated); 72dcpExecutorEvents.Subscribe<OnResourceStartingContext>(OnResourceStarting); 73dcpExecutorEvents.Subscribe<OnConnectionStringAvailableContext>(OnConnectionStringAvailable); 74dcpExecutorEvents.Subscribe<OnResourceFailedToStartContext>(OnResourceFailedToStart);
Aspire.Hosting.Tests (39)
Dcp\DcpExecutorTests.cs (39)
133events.Subscribe<OnResourceStartingContext>((context) => 140events.Subscribe<OnResourceChangedContext>(async (context) => 567events.Subscribe<OnConnectionStringAvailableContext>(context => 1685events.Subscribe<OnResourceChangedContext>(context => 1844events.Subscribe<OnResourceChangedContext>(context => 1933events.Subscribe<OnResourceChangedContext>(context => 2294events.Subscribe<OnResourceChangedContext>(context => 2450events.Subscribe<OnResourceChangedContext>(context => 2569events.Subscribe<OnResourceChangedContext>(context => 2622events.Subscribe<OnResourceChangedContext>(context => 2678events.Subscribe<OnResourceChangedContext>(context => 2774events.Subscribe<OnResourceChangedContext>(context => 2896events.Subscribe<OnResourceChangedContext>(context => 2968events.Subscribe<OnResourceChangedContext>(context => 3048events.Subscribe<OnResourceChangedContext>(context => 3769events.Subscribe<OnConnectionStringAvailableContext>(context => 3779events.Subscribe<OnResourceStartingContext>(context => 3828events.Subscribe<OnConnectionStringAvailableContext>(context => 3906events.Subscribe<OnResourceStartingContext>(async context => 3952events.Subscribe<OnResourceStartingContext>(async context => 4127dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 5031events.Subscribe<OnResourceFailedToStartContext>(context => 5538events.Subscribe<OnResourceFailedToStartContext>(context => 6610events.Subscribe<OnResourceFailedToStartContext>(context => 7474events.Subscribe<OnResourceFailedToStartContext>(context => 7990events.Subscribe<OnResourceFailedToStartContext>(context => 8322events.Subscribe<OnResourceFailedToStartContext>(context => 8492events.Subscribe<OnResourceFailedToStartContext>(context => 8568events.Subscribe<OnResourceFailedToStartContext>(context => 8763events.Subscribe<OnResourceFailedToStartContext>(context => 8976events.Subscribe<OnResourceFailedToStartContext>(context => 9060events.Subscribe<OnResourceStartingContext>(context => 9337events.Subscribe<OnResourceStartingContext>(context => 9415events.Subscribe<OnResourceStartingContext>(async context => 9476events.Subscribe<OnResourceStartingContext>(async context => 9547events.Subscribe<OnResourceFailedToStartContext>(c => 9584events.Subscribe<OnResourceFailedToStartContext>(c => 9665events.Subscribe<OnResourceFailedToStartContext>(context => 9756events.Subscribe<OnResourceFailedToStartContext>(context =>