1 write to InteractionId
Aspire.Hosting (1)
InteractionService.cs (1)
395InteractionId = Interlocked.Increment(ref s_nextInteractionId);
31 references to InteractionId
Aspire.Hosting (8)
Dashboard\DashboardService.cs (1)
74change.InteractionId = interaction.InteractionId;
InteractionService.cs (4)
165updateEvent = _interactionCollection.Remove(interactionUpdate.InteractionId); 169if (_interactionCollection.Contains(interactionUpdate.InteractionId)) 172throw new InvalidOperationException($"An interaction with ID {interactionUpdate.InteractionId} already exists. Interaction IDs must be unique."); 368protected override int GetKeyForItem(Interaction item) => item.InteractionId;
Publishing\PublishingActivityReporter.cs (3)
270await _interactionService.CompleteInteractionAsync(interaction.InteractionId, (interaction, ServiceProvider) => 301Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture), 331Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture),
Aspire.Hosting.Tests (23)
InteractionServiceTests.cs (23)
30await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = true }); 82id1 = interaction.InteractionId; 86id2 = interaction.InteractionId; 90id3 = interaction.InteractionId; 100interaction => Assert.Equal(interaction.InteractionId, id2), 101interaction => Assert.Equal(interaction.InteractionId, id3)); 107Assert.Equal(id3.Value, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 133Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 138Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 142await CompleteInteractionAsync(interactionService, interaction1.InteractionId, result1); 144Assert.Equal(interaction2.InteractionId, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 150await CompleteInteractionAsync(interactionService, interaction2.InteractionId, result2); 196await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 216await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 236await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 256await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 276await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 307await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 641await CompleteInteractionAsync(interactionService, interaction.InteractionId, 700await CompleteInteractionAsync(interactionService, interaction.InteractionId,