57 references to Interactions
Aspire.Hosting.Tests (57)
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 (37)
201var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 209var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 287var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 294var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 385var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 389var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 435var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 439var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 478var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 482var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 513var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 517var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 552var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 556var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 912var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 956var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 989var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1025var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1039var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1074var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1084var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1107var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1273var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1276var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1314var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1317var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1358var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1361var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1399var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1416var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1452var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1469var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1509var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1545var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1559var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1568var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1575var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
tests\Shared\TestInteractionService.cs (3)
31Interactions.Writer.TryWrite(data); 39Interactions.Writer.TryWrite(data); 54Interactions.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 _));