1 instantiation of BackchannelLogEntry
Aspire.Hosting (1)
Backchannel\BackchannelLoggerProvider.cs (1)
100
var entry = new
BackchannelLogEntry
19 references to BackchannelLogEntry
Aspire.Hosting (11)
Backchannel\AppHostRpcTarget.cs (3)
30
public async IAsyncEnumerable<
BackchannelLogEntry
> GetAppHostLogEntriesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
54
foreach (
var
entry in snapshot)
61
await foreach (
var
entry in AsyncEnumerableUtils.ReadUntilCancelledAsync(channel.Reader.ReadAllAsync(linkedToken), linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1937
public IAsyncEnumerable<
BackchannelLogEntry
> GetAppHostLogEntriesAsync(CancellationToken cancellationToken = default)
Backchannel\BackchannelLoggerProvider.cs (7)
11
private readonly Queue<
BackchannelLogEntry
> _replayBuffer = new();
13
private readonly Dictionary<int, Channel<
BackchannelLogEntry
>> _subscribers = [];
23
internal (List<
BackchannelLogEntry
> Snapshot, int SubscriberId, Channel<
BackchannelLogEntry
> Channel) Subscribe()
25
var channel = Channel.CreateUnbounded<
BackchannelLogEntry
>();
46
internal void WriteEntry(
BackchannelLogEntry
entry)
100
var
entry = new BackchannelLogEntry
Aspire.Hosting.Tests (8)
Backchannel\AppHostRpcTargetCancellationTests.cs (3)
34
await foreach (
var
_ in target.GetAppHostLogEntriesAsync(cts.Token))
55
await foreach (
var
_ in target.GetAppHostLogEntriesAsync(cts.Token))
79
await foreach (
var
_ in target.GetAppHostLogEntriesAsync(CancellationToken.None))
Backchannel\BackchannelLoggerProviderTests.cs (5)
66
var
entry = Assert.Single(snapshot);
137
Assert.True(channel1.Reader.TryRead(out
var
entry1a));
139
Assert.True(channel1.Reader.TryRead(out
var
entry1b));
142
Assert.True(channel2.Reader.TryRead(out
var
entry2a));
144
Assert.True(channel2.Reader.TryRead(out
var
entry2b));