1 write to InteractionId
Aspire.Hosting (1)
InteractionService.cs (1)
346InteractionId = Interlocked.Increment(ref s_nextInteractionId);
22 references to InteractionId
Aspire.Hosting (7)
Dashboard\DashboardService.cs (1)
74change.InteractionId = interaction.InteractionId;
InteractionService.cs (4)
161updateEvent = _interactionCollection.Remove(interactionUpdate.InteractionId); 165if (_interactionCollection.Contains(interactionUpdate.InteractionId)) 168throw new InvalidOperationException($"An interaction with ID {interactionUpdate.InteractionId} already exists. Interaction IDs must be unique."); 306protected override int GetKeyForItem(Interaction item) => item.InteractionId;
Publishing\PublishingActivityReporter.cs (2)
275await _interactionService.CompleteInteractionAsync(interaction.InteractionId, (interaction, ServiceProvider) => 303Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture),
Aspire.Hosting.Tests (15)
InteractionServiceTests.cs (15)
31await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = true }); 83id1 = interaction.InteractionId; 87id2 = interaction.InteractionId; 91id3 = interaction.InteractionId; 101interaction => Assert.Equal(interaction.InteractionId, id2), 102interaction => Assert.Equal(interaction.InteractionId, id3)); 108Assert.Equal(id3.Value, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 134Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 139Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 143await CompleteInteractionAsync(interactionService, interaction1.InteractionId, result1); 145Assert.Equal(interaction2.InteractionId, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 151await CompleteInteractionAsync(interactionService, interaction2.InteractionId, result2);