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