5 writes to Writer
System.Threading.Channels (5)
415 references to Writer
aspire (20)
Interaction\ExtensionInteractionService.cs (20)
65var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
69result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
76var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
79result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
89await _extensionTaskChannel.Writer.WriteAsync(async () =>
116await _extensionTaskChannel.Writer.WriteAsync(async () =>
145await _extensionTaskChannel.Writer.WriteAsync(async () =>
169var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken));
176var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken));
183var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayMessageAsync(emoji, message.RemoveSpectreFormatting(), _cancellationToken));
190var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken));
197var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken));
204var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken));
210var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken));
217var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken));
223var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken));
230var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.OpenProjectAsync(projectPath, _cancellationToken));
243var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markdown, _cancellationToken));
255var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, message.RemoveSpectreFormatting(), _cancellationToken));
271var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.NotifyAppHostStartupCompletedAsync(_cancellationToken));
Aspire.Cli.Tests (8)
Aspire.Components.Common.TestUtilities (2)
Aspire.Confluent.Kafka (1)
Aspire.Dashboard (8)
Aspire.Dashboard.Components.Tests (33)
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();
327consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]);
375consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
426consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
468consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
484consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
528consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
540consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
596resourceChannel.Writer.TryWrite([
663resourceCommandChannel.Writer.TryWrite(new ResourceCommandResponseViewModel
722consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]);
723consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]);
724consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]);
766consoleLogsChannel.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)
133await resultChannel.Writer.WriteAsync(++changeCount);
151await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting)));
159await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting)));
167await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running)));
171resultChannel.Writer.Complete();
Aspire.Hosting (27)
Aspire.Hosting.Azure.Tests (2)
Aspire.Hosting.Tests (32)
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.Threading.Package (5)
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)