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>

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;