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)
35var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 95interactionService.Interactions.Writer.Complete(); 99Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 129var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 172var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 179interactionService.Interactions.Writer.Complete(); 180Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 210interactionService.Interactions.Writer.Complete(); 215Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 239interactionService.Interactions.Writer.Complete(); 244Assert.False(interactionService.Interactions.Reader.TryRead(out var _));