5 writes to Writer
System.Threading.Channels (5)
401 references to Writer
aspire (18)
Interaction\ExtensionInteractionService.cs (18)
55var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
59result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
66var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken));
69result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken));
79await _extensionTaskChannel.Writer.WriteAsync(async () =>
106await _extensionTaskChannel.Writer.WriteAsync(async () =>
135await _extensionTaskChannel.Writer.WriteAsync(async () =>
159var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken));
166var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken));
173var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayMessageAsync(emoji, message.RemoveSpectreFormatting(), _cancellationToken));
180var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken));
187var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken));
194var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken));
201var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken));
208var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken));
214var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken));
221var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.OpenProjectAsync(projectPath, _cancellationToken));
237Debug.Assert(_extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, message.RemoveSpectreFormatting(), _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 (31)
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.Threading.Channels (2)
Test.Utilities (7)
TestDiscoveryWorker (2)
Text.Analyzers (7)