1 write to InteractionId
Aspire.Hosting (1)
InteractionService.cs (1)
398InteractionId = Interlocked.Increment(ref s_nextInteractionId);
32 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."); 371protected override int GetKeyForItem(Interaction item) => item.InteractionId;
Publishing\PublishingActivityReporter.cs (3)
270await _interactionService.CompleteInteractionAsync(interaction.InteractionId, (interaction, ServiceProvider) => 302Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture), 332Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture),
Aspire.Hosting.Tests (24)
InteractionServiceTests.cs (24)
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 } }); 274await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 294await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 325await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = new[] { input } }); 659await CompleteInteractionAsync(interactionService, interaction.InteractionId, 718await CompleteInteractionAsync(interactionService, interaction.InteractionId,