29 references to Interactions
Aspire.Hosting.Tests (29)
Dcp\DcpHostNotificationTests.cs (6)
80var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 133await interactionService.Interactions.Reader.ReadAsync(cts.Token); 188await interactionService.Interactions.Reader.ReadAsync(cts.Token); 239var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 290var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 353var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Orchestrator\ParameterProcessorTests.cs (10)
191var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 199var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 277var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 284var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 375var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 379var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 422var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 426var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 462var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 466var 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 _));