Interactions

85 references to Interactions

Aspire.Hosting.Tests (85)

AtsInteractionExportsTests.cs (2)

29var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 56var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();

Dcp\DcpHostNotificationTests.cs (13)

112var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 156var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 213await interactionService.Interactions.Reader.ReadAsync(cts.Token); 272await interactionService.Interactions.Reader.ReadAsync(cts.Token); 327var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 382var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 453var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 887await interactionService.Interactions.Reader.ReadAsync(cts.Token); 937await interactionService.Interactions.Reader.ReadAsync(cts.Token); 993var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 1048await interactionService.Interactions.Reader.ReadAsync(cts.Token); 1106await interactionService.Interactions.Reader.ReadAsync(cts.Token); 1167var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);

DotnetProgramPublishingTests.cs (3)

390var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 399Assert.False(interactions.Interactions.Reader.TryRead(out _)); 419Assert.False(interactions.Interactions.Reader.TryRead(out _));

Orchestrator\ParameterProcessorTests.cs (28)

202var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 210var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 295var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 306Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 395var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 399var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 445var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 449var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 488var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 492var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 523var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 527var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 562var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 566var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1128var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1174var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1413var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1416var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1454var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1457var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1498var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1501var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1584var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1589var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1613var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1623var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1635var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1639var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();

Publishing\ContainerRuntimeReadinessTests.cs (8)

26Assert.False(interactions.Interactions.Reader.TryRead(out _)); 42Assert.False(interactions.Interactions.Reader.TryRead(out _)); 57var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 64Assert.False(interactions.Interactions.Reader.TryRead(out _)); 87var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 96Assert.False(interactions.Interactions.Reader.TryRead(out _)); 131var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 164var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout();

RequiredCommandAnnotationTests.cs (4)

403var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 434Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 459var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 467Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));

ResourceCommandServiceTests.cs (5)

1299var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1473var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1530Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1866var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1919var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();

tests\Shared\TestInteractionService.cs (5)

46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);

VersionChecking\VersionCheckServiceTests.cs (17)

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 _)); 282interactionService.Interactions.Writer.Complete(); 283Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 287var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 317var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 346var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();