35 references to Interactions
Aspire.Hosting.Tests (35)
Dcp\DcpHostNotificationTests.cs (6)
90var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 143await interactionService.Interactions.Reader.ReadAsync(cts.Token); 198await interactionService.Interactions.Reader.ReadAsync(cts.Token); 249var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 300var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 367var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Orchestrator\ParameterProcessorTests.cs (16)
195var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 203var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 281var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 288var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 379var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 383var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 426var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 430var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 466var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 470var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 881var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 884var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 920var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 923var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 962var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 965var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
tests\Shared\TestInteractionService.cs (2)
36Interactions.Writer.TryWrite(data); 51Interactions.Writer.TryWrite(data);
VersionChecking\VersionCheckServiceTests.cs (11)
37var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 97interactionService.Interactions.Writer.Complete(); 101Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 131var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 174var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 181interactionService.Interactions.Writer.Complete(); 182Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 212interactionService.Interactions.Writer.Complete(); 217Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 241interactionService.Interactions.Writer.Complete(); 246Assert.False(interactionService.Interactions.Reader.TryRead(out var _));