55 references to Subscribe
Aspire.Hosting (6)
Orchestrator\ApplicationOrchestrator.cs (6)
70dcpExecutorEvents.Subscribe<OnResourcesPreparedContext>(OnResourcesPrepared); 71dcpExecutorEvents.Subscribe<OnResourceChangedContext>(OnResourceChanged); 72dcpExecutorEvents.Subscribe<OnEndpointsAllocatedContext>(OnEndpointsAllocated); 73dcpExecutorEvents.Subscribe<OnResourceStartingContext>(OnResourceStarting); 74dcpExecutorEvents.Subscribe<OnConnectionStringAvailableContext>(OnConnectionStringAvailable); 75dcpExecutorEvents.Subscribe<OnResourceFailedToStartContext>(OnResourceFailedToStart);
Aspire.Hosting.Tests (49)
Dcp\DcpExecutorTests.cs (49)
64events.Subscribe<OnResourceChangedContext>(async context => 131events.Subscribe<OnResourceChangedContext>(context => 227events.Subscribe<OnResourceChangedContext>(context => 290events.Subscribe<OnResourceStartingContext>(context => 487events.Subscribe<OnResourceStartingContext>((context) => 494events.Subscribe<OnResourceChangedContext>(async (context) => 921events.Subscribe<OnConnectionStringAvailableContext>(context => 2135events.Subscribe<OnResourceChangedContext>(context => 2294events.Subscribe<OnResourceChangedContext>(context => 2383events.Subscribe<OnResourceChangedContext>(context => 2744events.Subscribe<OnResourceChangedContext>(context => 2900events.Subscribe<OnResourceChangedContext>(context => 3012events.Subscribe<OnResourceChangedContext>(context => 3080events.Subscribe<OnResourceChangedContext>(context => 3132events.Subscribe<OnResourceChangedContext>(context => 3185events.Subscribe<OnResourceChangedContext>(context => 3241events.Subscribe<OnResourceChangedContext>(context => 3337events.Subscribe<OnResourceChangedContext>(context => 3459events.Subscribe<OnResourceChangedContext>(context => 3531events.Subscribe<OnResourceChangedContext>(context => 3611events.Subscribe<OnResourceChangedContext>(context => 4490events.Subscribe<OnConnectionStringAvailableContext>(context => 4500events.Subscribe<OnResourceStartingContext>(context => 4515events.Subscribe<OnEndpointsAllocatedContext>(context => orchestrator.PublishEndpointsAllocatedAsync( 4553events.Subscribe<OnConnectionStringAvailableContext>(context => 4631events.Subscribe<OnResourceStartingContext>(async context => 4677events.Subscribe<OnResourceStartingContext>(async context => 4968dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 5951events.Subscribe<OnResourceFailedToStartContext>(context => 6458events.Subscribe<OnResourceFailedToStartContext>(context => 7530events.Subscribe<OnResourceFailedToStartContext>(context => 8452events.Subscribe<OnResourceFailedToStartContext>(context => 8968events.Subscribe<OnResourceFailedToStartContext>(context => 9300events.Subscribe<OnResourceFailedToStartContext>(context => 9470events.Subscribe<OnResourceFailedToStartContext>(context => 9546events.Subscribe<OnResourceFailedToStartContext>(context => 9741events.Subscribe<OnResourceFailedToStartContext>(context => 9959events.Subscribe<OnResourceFailedToStartContext>(context => 10043events.Subscribe<OnResourceStartingContext>(context => 10320events.Subscribe<OnResourceStartingContext>(context => 10592events.Subscribe<OnResourceFailedToStartContext>(context => 10660events.Subscribe<OnResourceFailedToStartContext>(context => 10838events.Subscribe<OnResourceFailedToStartContext>(context => 10904events.Subscribe<OnResourceStartingContext>(async context => 10965events.Subscribe<OnResourceStartingContext>(async context => 11036events.Subscribe<OnResourceFailedToStartContext>(c => 11073events.Subscribe<OnResourceFailedToStartContext>(c => 11154events.Subscribe<OnResourceFailedToStartContext>(context => 11245events.Subscribe<OnResourceFailedToStartContext>(context =>