54 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 (48)
Dcp\DcpExecutorTests.cs (48)
62events.Subscribe<OnResourceChangedContext>(async context => 129events.Subscribe<OnResourceChangedContext>(context => 225events.Subscribe<OnResourceChangedContext>(context => 288events.Subscribe<OnResourceStartingContext>(context => 485events.Subscribe<OnResourceStartingContext>((context) => 492events.Subscribe<OnResourceChangedContext>(async (context) => 919events.Subscribe<OnConnectionStringAvailableContext>(context => 2133events.Subscribe<OnResourceChangedContext>(context => 2292events.Subscribe<OnResourceChangedContext>(context => 2381events.Subscribe<OnResourceChangedContext>(context => 2742events.Subscribe<OnResourceChangedContext>(context => 2898events.Subscribe<OnResourceChangedContext>(context => 3010events.Subscribe<OnResourceChangedContext>(context => 3078events.Subscribe<OnResourceChangedContext>(context => 3130events.Subscribe<OnResourceChangedContext>(context => 3183events.Subscribe<OnResourceChangedContext>(context => 3239events.Subscribe<OnResourceChangedContext>(context => 3335events.Subscribe<OnResourceChangedContext>(context => 3457events.Subscribe<OnResourceChangedContext>(context => 3529events.Subscribe<OnResourceChangedContext>(context => 3609events.Subscribe<OnResourceChangedContext>(context => 4488events.Subscribe<OnConnectionStringAvailableContext>(context => 4498events.Subscribe<OnResourceStartingContext>(context => 4547events.Subscribe<OnConnectionStringAvailableContext>(context => 4625events.Subscribe<OnResourceStartingContext>(async context => 4671events.Subscribe<OnResourceStartingContext>(async context => 4846dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 5750events.Subscribe<OnResourceFailedToStartContext>(context => 6257events.Subscribe<OnResourceFailedToStartContext>(context => 7329events.Subscribe<OnResourceFailedToStartContext>(context => 8251events.Subscribe<OnResourceFailedToStartContext>(context => 8767events.Subscribe<OnResourceFailedToStartContext>(context => 9099events.Subscribe<OnResourceFailedToStartContext>(context => 9269events.Subscribe<OnResourceFailedToStartContext>(context => 9345events.Subscribe<OnResourceFailedToStartContext>(context => 9540events.Subscribe<OnResourceFailedToStartContext>(context => 9753events.Subscribe<OnResourceFailedToStartContext>(context => 9837events.Subscribe<OnResourceStartingContext>(context => 10114events.Subscribe<OnResourceStartingContext>(context => 10386events.Subscribe<OnResourceFailedToStartContext>(context => 10454events.Subscribe<OnResourceFailedToStartContext>(context => 10632events.Subscribe<OnResourceFailedToStartContext>(context => 10698events.Subscribe<OnResourceStartingContext>(async context => 10759events.Subscribe<OnResourceStartingContext>(async context => 10830events.Subscribe<OnResourceFailedToStartContext>(c => 10867events.Subscribe<OnResourceFailedToStartContext>(c => 10948events.Subscribe<OnResourceFailedToStartContext>(context => 11039events.Subscribe<OnResourceFailedToStartContext>(context =>