ChannelWriter

5 types derived from ChannelWriter

System.Threading.Channels (5)

System\Threading\Channels\BoundedChannel.cs (1)

292private sealed class BoundedChannelWriter : ChannelWriter<T>, IDebugEnumerable<T>

System\Threading\Channels\RendezvousChannel.cs (1)

239private sealed class RendezvousChannelWriter : ChannelWriter<T>

System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)

204private sealed class UnboundedChannelWriter : ChannelWriter<T>, IDebugEnumerable<T>

System\Threading\Channels\UnboundedChannel.cs (1)

183private sealed class UnboundedChannelWriter : ChannelWriter<T>, IDebugEnumerable<T>

System\Threading\Channels\UnboundedPriorityChannel.cs (1)

188private sealed class UnboundedPrioritizedChannelWriter : ChannelWriter<T>, IDebugEnumerable<T>

29 references to ChannelWriter

aspire (2)

Projects\ProjectLocator.cs (2)

233ChannelWriter<AppHostProjectCandidate> candidateWriter, 289private async Task<(List<AppHostProjectCandidate> BuildableAppHost, List<AppHostProjectCandidate> UnbuildableSuspectedAppHostProjects, List<FileInfo> UnsupportedProjects)> FindAppHostProjectFilesAsync(DirectoryInfo searchDirectory, bool stopAfterMultipleBuildableAppHosts, bool displayProgress, AppHostDiscoveryScope scope, int? maxDepth, ChannelWriter<AppHostProjectCandidate>? candidateWriter = null, Action<int>? onDirectoryEnumerated = null, CancellationToken cancellationToken = default)

Aspire.Confluent.Kafka (1)

MetricsChannel.cs (1)

24public ChannelWriter<string> Writer => _channel.Writer;

Aspire.Confluent.Kafka.Tests (4)

Aspire8MetricsTests.cs (4)

44var writer = GetMetricsChannelWriter(metricsChannel)!; 159var writer = GetMetricsChannelWriter(metricsChannel)!; 246private static ChannelWriter<string>? GetMetricsChannelWriter(object o) => ReflectionHelpers.MetricsChannelType.Value.GetProperty("Writer")!.GetValue(o) as ChannelWriter<string>;

GenerateDocumentationAndConfigFiles (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Microsoft.AspNetCore.Server.Kestrel.Transport.DirectTls (3)

TlsEventPump.cs (2)

86private ChannelWriter<DirectTlsConnection>? _readyConnections; 198ChannelWriter<DirectTlsConnection> readyConnections,

TlsEventPumpPool.cs (1)

53ChannelWriter<DirectTlsConnection> readyConnections,

Microsoft.AspNetCore.SignalR.Client.Core (1)

HubConnection.cs (1)

1595private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter)

Microsoft.CodeAnalysis.Analyzers (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Microsoft.CodeAnalysis.CodeStyle (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Microsoft.CodeAnalysis.Workspaces (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

Roslyn.Diagnostics.Analyzers (2)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

378ChannelWriter<TItem> writer,

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

59static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)

System.Threading.Channels (4)

System\Threading\Channels\AsyncOperation.cs (2)

603/// <summary>Represents a blocked writer from <see cref="ChannelWriter{T}.WriteAsync"/>.</summary> 627/// <summary>Represents a waiting writer from <see cref="ChannelWriter{T}.WaitToWriteAsync"/>.</summary>

System\Threading\Channels\Channel_2.cs (2)

18public ChannelWriter<TWrite> Writer { get; protected set; } = null!; // derived types should always set the Writer as part of construction 26public static implicit operator ChannelWriter<TWrite>(Channel<TWrite, TRead> channel) => channel.Writer;