1 instantiation of BackchannelLogEntry
Aspire.Hosting (1)
Backchannel\BackchannelLoggerProvider.cs (1)
95
var entry = new
BackchannelLogEntry
15 references to BackchannelLogEntry
Aspire.Hosting (11)
Backchannel\AppHostRpcTarget.cs (3)
24
public async IAsyncEnumerable<
BackchannelLogEntry
> GetAppHostLogEntriesAsync([EnumeratorCancellation] CancellationToken cancellationToken)
42
foreach (
var
entry in snapshot)
48
await foreach (
var
entry in channel.Reader.ReadAllAsync(linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
918
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 = [];
21
internal (List<
BackchannelLogEntry
> Snapshot, int SubscriberId, Channel<
BackchannelLogEntry
> Channel) Subscribe()
23
var channel = Channel.CreateUnbounded<
BackchannelLogEntry
>();
44
internal void WriteEntry(
BackchannelLogEntry
entry)
95
var
entry = new BackchannelLogEntry
Aspire.Hosting.Tests (4)
Backchannel\BackchannelLoggerProviderTests.cs (4)
97
Assert.True(channel1.Reader.TryRead(out
var
entry1a));
99
Assert.True(channel1.Reader.TryRead(out
var
entry1b));
102
Assert.True(channel2.Reader.TryRead(out
var
entry2a));
104
Assert.True(channel2.Reader.TryRead(out
var
entry2b));