ChannelWriter

4 types derived from ChannelWriter

System.Threading.Channels (4)

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

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

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

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

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

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

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

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

16 references to ChannelWriter

Aspire.Confluent.Kafka (1)

MetricsChannel.cs (1)

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

Aspire.Confluent.Kafka.Tests (4)

MetricsTests.cs (4)

45ChannelWriter<string> writer = GetMetricsChannelWriter(metricsChannel)!; 162ChannelWriter<string> writer = GetMetricsChannelWriter(metricsChannel)!; 250private static ChannelWriter<string>? GetMetricsChannelWriter(object o) => ReflectionHelpers.MetricsChannelType.Value!.GetProperty("Writer")!.GetValue(o) as ChannelWriter<string>;

ClientSample (1)

UploadSample.cs (1)

68async Task WriteItemsAsync(ChannelWriter<int> source, IEnumerable<int> scores)

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

55var writer = _counters[counter].Writer;

Microsoft.AspNetCore.Hosting.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

55var writer = _counters[counter].Writer;

Microsoft.AspNetCore.Http.Connections.Tests (2)

TestWebSocketConnectionFeature.cs (2)

60private readonly ChannelWriter<WebSocketMessage> _output; 68public WebSocketChannel(ChannelReader<WebSocketMessage> input, ChannelWriter<WebSocketMessage> output, SyncPoint sync = null)

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

HubConnection.cs (1)

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

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

298async Task ChannelFunc(ChannelWriter<string> output, ChannelReader<string> input)

Microsoft.CodeAnalysis.CodeStyle (1)

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

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

Microsoft.CodeAnalysis.Workspaces (1)

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

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

System.Threading.Channels (2)

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;