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>
23 references to ChannelWriter
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)
65static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)
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)
65static 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)
65static 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)
65static 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)
65static 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)
65static 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)
65static async Task ProcessAsync(IAsyncEnumerable<T> stream, ChannelWriter<T> writer, CancellationToken cancellationToken)
System.Threading.Channels (4)
System\Threading\Channels\AsyncOperation.cs (2)
602/// <summary>Represents a blocked writer from <see cref="ChannelWriter{T}.WriteAsync"/>.</summary> 626/// <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;