29 references to Interactions
Aspire.Hosting.Tests (29)
Dcp\DcpHostNotificationTests.cs (6)
83var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 136await interactionService.Interactions.Reader.ReadAsync(cts.Token); 191await interactionService.Interactions.Reader.ReadAsync(cts.Token); 242var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 293var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 360var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Orchestrator\ParameterProcessorTests.cs (10)
193var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 201var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 279var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 286var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 377var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 381var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 424var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 428var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 464var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 468var 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 _));