29 references to Interactions
Aspire.Hosting.Tests (29)
Dcp\DcpHostNotificationTests.cs (6)
82var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 135await interactionService.Interactions.Reader.ReadAsync(cts.Token); 190await interactionService.Interactions.Reader.ReadAsync(cts.Token); 241var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 292var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 355var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Orchestrator\ParameterProcessorTests.cs (10)
192var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 200var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 278var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 285var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 376var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 380var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 423var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 427var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 463var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 467var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
tests\Shared\TestInteractionService.cs (2)
36Interactions.Writer.TryWrite(data); 51Interactions.Writer.TryWrite(data);
VersionChecking\VersionCheckServiceTests.cs (11)
34var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 94interactionService.Interactions.Writer.Complete(); 98Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 128var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 171var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 178interactionService.Interactions.Writer.Complete(); 179Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 209interactionService.Interactions.Writer.Complete(); 214Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 238interactionService.Interactions.Writer.Complete(); 243Assert.False(interactionService.Interactions.Reader.TryRead(out var _));