35 instantiations of ResourceLogLine
Aspire.Dashboard (4)
ServiceClient\DashboardClient.cs (1)
1084resourceLogLines[i] = new ResourceLogLine(logLines[i].LineNumber, logLines[i].Text, logLines[i].IsStdErr);
ServiceClient\SqliteResourceRepository.cs (3)
104.Select(line => new ResourceLogLine(line.LineNumber, line.Content, line.IsStdErr)) 132.Select(line => new ResourceLogLine(line.LineNumber, line.Content, line.IsStdErr)) 320var viewModelLines = logLines.Select(line => new ResourceLogLine(line.LineNumber, line.Text, line.IsStdErr)).ToArray();
Aspire.Dashboard.Components.Tests (16)
Pages\ConsoleLogsTerminalTests.cs (1)
41await logs.Writer.WriteAsync([new ResourceLogLine(1, "startup output", false)]);
Pages\ConsoleLogsTests.cs (15)
132consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]); 359consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]); 399liveConsoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Live log", IsErrorMessage: false)]); 447new ResourceLogLine(1, "apple log", IsErrorMessage: false), 448new ResourceLogLine(2, "banana log", IsErrorMessage: false) 629consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 654consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 735consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 747consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 775new ResourceLogLine(1, clearedLog, IsErrorMessage: false), 776new ResourceLogLine(2, newLog, IsErrorMessage: false) 1021consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]); 1022consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]); 1023consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]); 1069consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(4, resumeContent, IsErrorMessage: false)]);
Aspire.Dashboard.Tests (15)
Model\DashboardClientTests.cs (1)
471Assert.Equal(new ResourceLogLine(1, "Hello", false), line);
Model\SqliteResourceRepositoryTests.cs (14)
126line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(2, "second", true), line), 127line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(1, "first", false), line), 128line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(3, "third", false), line), 129line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(4, "fourth", false), line)); 165line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(4, "2025-02-08T10:16:09Z api-fourth-after-clear", false), line)); 174line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(1, "worker-first", false), line)); 212line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(1, "first", false), line), 213line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(2, "second", false), line), 214line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(1, "new-first", false), line), 215line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(2, "new-second", false), line), 216line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(3, "new-third", false), line)); 270line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(2, "api-second", false), line)); 279line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(1, "worker-first", false), line), 280line => Assert.Equal(new global::Aspire.Dashboard.Model.ResourceLogLine(2, "worker-second", false), line));
70 references to ResourceLogLine
Aspire.Dashboard (19)
Model\ConsoleLogsFetcher.cs (1)
42foreach (var logLine in batch)
ServiceClient\DashboardClient.cs (5)
993public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 1013var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>( 1041public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 1078private static ResourceLogLine[] CreateLogLines(IList<ConsoleLogLine> logLines) 1080var resourceLogLines = new ResourceLogLine[logLines.Count];
ServiceClient\IResourceRepository.cs (2)
31IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken); 36IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken);
ServiceClient\SelectedDashboardClient.cs (2)
42public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) => 46public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) =>
ServiceClient\SqliteResourceRepository.cs (9)
28private readonly Dictionary<string, ImmutableHashSet<Channel<IReadOnlyList<ResourceLogLine>>>> _consoleChannels = new(StringComparers.ResourceName); 91public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs( 95ResourceLogLine[] lines; 114public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs( 118ResourceLogLine[] initialLines; 119Channel<IReadOnlyList<ResourceLogLine>> channel; 135channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(new UnboundedChannelOptions 321Channel<IReadOnlyList<ResourceLogLine>>[] channels; 533Channel<IReadOnlyList<ResourceLogLine>>[] consoleChannels;
Aspire.Dashboard.Components.Tests (26)
Pages\ConsoleLogsTerminalTests.cs (1)
27var logs = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();
Pages\ConsoleLogsTests.cs (21)
41var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 91var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 151consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 180var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 269var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 321var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 368var liveConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 369var repositoryConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 413consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 431var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 472var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 498var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 547var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 596var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 661var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 699var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 754var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 795var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 871consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 904var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 963var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();
tests\Shared\TestDashboardClient.cs (4)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 162public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 177public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Playwright.Tests (6)
tests\Aspire.Dashboard.Tests\Shared\MockDashboardClient.cs (2)
63public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 69public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
tests\Shared\TestDashboardClient.cs (4)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 162public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 177public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Tests (19)
Model\DashboardClientTests.cs (2)
464var batches = new List<IReadOnlyList<ResourceLogLine>>(); 470var line = Assert.Single(Assert.Single(batches));
Model\SqliteResourceRepositoryTests.cs (7)
119var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.ResourceLogLine>>(); 158var apiBatches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.ResourceLogLine>>(); 167var workerBatches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.ResourceLogLine>>(); 204var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.ResourceLogLine>>(); 233var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.ResourceLogLine>>(); 263var apiLogs = new List<global::Aspire.Dashboard.Model.ResourceLogLine>(); 272var workerLogs = new List<global::Aspire.Dashboard.Model.ResourceLogLine>();
ResourceOutgoingPeerResolverTests.cs (2)
703public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException(); 706public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
Shared\MockDashboardClient.cs (2)
63public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 69public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Terminal\DefaultTerminalConnectionResolverTests.cs (2)
201public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException(); 202public IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
tests\Shared\TestDashboardClient.cs (4)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 162public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 177public async IAsyncEnumerable<IReadOnlyList<ResourceLogLine>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)