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 => 1781events.Subscribe<OnResourceChangedContext>(context => 1940events.Subscribe<OnResourceChangedContext>(context => 2029events.Subscribe<OnResourceChangedContext>(context => 2390events.Subscribe<OnResourceChangedContext>(context => 2546events.Subscribe<OnResourceChangedContext>(context => 2665events.Subscribe<OnResourceChangedContext>(context => 2718events.Subscribe<OnResourceChangedContext>(context => 2774events.Subscribe<OnResourceChangedContext>(context => 2870events.Subscribe<OnResourceChangedContext>(context => 2992events.Subscribe<OnResourceChangedContext>(context => 3064events.Subscribe<OnResourceChangedContext>(context => 3144events.Subscribe<OnResourceChangedContext>(context => 3876events.Subscribe<OnConnectionStringAvailableContext>(context => 3886events.Subscribe<OnResourceStartingContext>(context => 3935events.Subscribe<OnConnectionStringAvailableContext>(context => 4013events.Subscribe<OnResourceStartingContext>(async context => 4059events.Subscribe<OnResourceStartingContext>(async context => 4234dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 5138events.Subscribe<OnResourceFailedToStartContext>(context => 5645events.Subscribe<OnResourceFailedToStartContext>(context => 6717events.Subscribe<OnResourceFailedToStartContext>(context => 7581events.Subscribe<OnResourceFailedToStartContext>(context => 8097events.Subscribe<OnResourceFailedToStartContext>(context => 8429events.Subscribe<OnResourceFailedToStartContext>(context => 8599events.Subscribe<OnResourceFailedToStartContext>(context => 8675events.Subscribe<OnResourceFailedToStartContext>(context => 8870events.Subscribe<OnResourceFailedToStartContext>(context => 9083events.Subscribe<OnResourceFailedToStartContext>(context => 9167events.Subscribe<OnResourceStartingContext>(context => 9444events.Subscribe<OnResourceStartingContext>(context => 9522events.Subscribe<OnResourceStartingContext>(async context => 9583events.Subscribe<OnResourceStartingContext>(async context => 9654events.Subscribe<OnResourceFailedToStartContext>(c => 9691events.Subscribe<OnResourceFailedToStartContext>(c => 9772events.Subscribe<OnResourceFailedToStartContext>(context => 9863events.Subscribe<OnResourceFailedToStartContext>(context =>