5 writes to Writer
System.Threading.Channels (5)
390 references to Writer
aspire (17)
Interaction\ExtensionInteractionService.cs (17)
47Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)));
50Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.ShowStatusAsync(null, _cancellationToken)));
56Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)));
58Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.ShowStatusAsync(null, _cancellationToken)));
68await _extensionTaskChannel.Writer.WriteAsync(async () =>
100await _extensionTaskChannel.Writer.WriteAsync(async () =>
134await _extensionTaskChannel.Writer.WriteAsync(async () =>
163Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken)));
169Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken)));
175Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayMessageAsync(emoji, message.RemoveSpectreFormatting(), _cancellationToken)));
181Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken)));
187Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken)));
193Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken)));
199Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken)));
205Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayCancellationMessageAsync(_cancellationToken)));
211Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.DisplayEmptyLineAsync(_cancellationToken)));
217Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => _backchannel.OpenProjectAsync(projectPath, _cancellationToken)));
Aspire.Cli.Tests (3)
Aspire.Components.Common.TestUtilities (2)
Aspire.Confluent.Kafka (1)
Aspire.Dashboard (8)
Aspire.Dashboard.Components.Tests (28)
Pages\ConsoleLogsTests.cs (18)
54subscribedResourceNamesChannel.Writer.TryWrite(name);
105subscribedResourceNamesChannel.Writer.TryWrite(name);
137consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]);
138consoleLogsChannel.Writer.Complete();
172subscribedResourceNamesChannel.Writer.Complete();
220consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]);
268consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
319consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
361consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
377consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
421consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
433consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
489resourceChannel.Writer.TryWrite([
556resourceCommandChannel.Writer.TryWrite(new ResourceCommandResponseViewModel
615consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]);
616consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]);
617consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]);
659consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(4, resumeContent, IsErrorMessage: false)]);
Aspire.Dashboard.Tests (20)
ChannelExtensionsTests.cs (11)
21channel.Writer.TryWrite(["a", "b", "c"]);
45channel.Writer.TryWrite(["a", "b", "c"]);
71channel.Writer.TryWrite(["a", "b", "c"]);
80resultChannel.Writer.TryWrite(batch);
85resultChannel.Writer.Complete();
94channel.Writer.TryWrite(["d", "e", "f"]);
102channel.Writer.Complete();
115channel.Writer.TryWrite(["a", "b", "c"]);
124resultChannel.Writer.TryWrite(batch);
129resultChannel.Writer.Complete();
138channel.Writer.TryWrite(["d", "e", "f"]);
ResourceOutgoingPeerResolverTests.cs (5)
132await resultChannel.Writer.WriteAsync(++changeCount);
150await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting)));
158await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting)));
166await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running)));
170resultChannel.Writer.Complete();
Aspire.Hosting (26)
Aspire.Hosting.Tests (28)
ClientSample (5)
GenerateDocumentationAndConfigFiles (7)
InMemory.FunctionalTests (9)
Metrics (7)
Metrics.Legacy (7)
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (2)
Microsoft.AspNetCore.Hosting.Tests (2)
Microsoft.AspNetCore.Http.Connections.Tests (2)
Microsoft.AspNetCore.Server.Kestrel.Core (5)
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (7)
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (4)
Microsoft.AspNetCore.SignalR.Client.Core (13)
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
Microsoft.AspNetCore.SignalR.Client.Tests (9)
Microsoft.AspNetCore.SignalR.Core (5)
Microsoft.AspNetCore.SignalR.Microbenchmarks (5)
Microsoft.AspNetCore.SignalR.Tests (35)
Microsoft.CodeAnalysis.Analyzers (7)
Microsoft.CodeAnalysis.AnalyzerUtilities (7)
Microsoft.CodeAnalysis.BannedApiAnalyzers (7)
Microsoft.CodeAnalysis.CodeStyle (7)
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (7)
Microsoft.CodeAnalysis.PublicApiAnalyzers (7)
Microsoft.CodeAnalysis.ResxSourceGenerator (7)
Microsoft.CodeAnalysis.Workspaces (7)
Microsoft.Extensions.AI (2)
Microsoft.Extensions.ServiceDiscovery.Tests (1)
Microsoft.ML.Data (1)
Microsoft.ML.Sweeper (2)
Roslyn.Diagnostics.Analyzers (7)
SignalR.Client.FunctionalTestApp (5)
SignalRSamples (8)
Stress.ApiService (4)
System.Net.Http (2)
System.Net.Quic (9)
System.Threading.Channels (2)
Test.Utilities (7)
TestDiscoveryWorker (2)
Text.Analyzers (7)