ChannelReader

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

70private sealed class BoundedChannelReader : ChannelReader<T>, IDebugEnumerable<T>

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

60private sealed class RendezvousChannelReader : ChannelReader<T>

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

53private sealed class UnboundedChannelReader : ChannelReader<T>, IDebugEnumerable<T>

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

47private sealed class UnboundedChannelReader : ChannelReader<T>, IDebugEnumerable<T>

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

54private sealed class UnboundedPrioritizedChannelReader : ChannelReader<T>, IDebugEnumerable<T>

Backchannel\ResourceSnapshotWatcherTests.cs (1)

557ChannelReader<ResourceSnapshot> source,

MetricsChannel.cs (1)

23public ChannelReader<string> Reader => _channel.Reader;

Devcontainers\DevcontainerSettingsWriter.cs (1)

69var reader = _portUpdates.Reader;

Publishing\PipelineActivityReporterTests.cs (30)

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

17public static IAsyncEnumerable<T> ReadAllAsync<T>(ChannelReader<T> reader, CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

HubConnection.cs (8)

459/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="ChannelReader{T}"/> for the streamed hub method values. 464public virtual async Task<ChannelReader<object?>> StreamAsChannelCoreAsync(string methodName, Type returnType, object?[] args, CancellationToken cancellationToken = default) 968var reader = await StreamAsChannelCoreAsync(methodName, typeof(T), args, cts.Token).ConfigureAwait(false); 987private async Task<ChannelReader<object?>> StreamAsChannelCoreAsyncCore(string methodName, Type returnType, object?[] args, CancellationToken cancellationToken) 995ChannelReader<object?> channel; 1130throw new InvalidOperationException($"{reader.GetType()} is not a {typeof(ChannelReader<>).Name}."); 1198private Task SendStreamItems<T>(ConnectionState connectionState, string streamId, ChannelReader<T> reader, CancellationTokenSource tokenSource) 1924async Task StartProcessingInvocationMessages(ChannelReader<InvocationMessage> invocationMessageChannelReader)

HubConnectionExtensions.StreamAsChannelAsync.cs (26)

Internal\InvocationRequest.cs (2)

57ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out ChannelReader<object?> result) 95public ChannelReader<object?> Result => _channel.Reader;

src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (5)

27public static IAsyncEnumerator<object?> MakeAsyncEnumeratorFromChannel<T>(ChannelReader<T> channel, CancellationToken cancellationToken = default) 34private readonly ChannelReader<T> _channel; 36public ChannelAsyncEnumerator(ChannelReader<T> channel, CancellationToken cancellationToken) 201private static readonly MethodInfo _channelReaderTryReadMethodInfo = typeof(ChannelReader<>).GetMethod("TryRead")!; 202private static readonly MethodInfo _channelReaderWaitToReadAsyncMethodInfo = typeof(ChannelReader<>).GetMethod("WaitToReadAsync")!;

src\aspnetcore\src\SignalR\common\Shared\ReflectionHelper.cs (1)

33if (nullableType.IsGenericType && nullableType.GetGenericTypeDefinition() == typeof(ChannelReader<>))

Internal\HubMethodDescriptor.cs (1)

51if (returnType.IsGenericType && returnType.GetGenericTypeDefinition() == typeof(ChannelReader<>))

src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (5)

27public static IAsyncEnumerator<object?> MakeAsyncEnumeratorFromChannel<T>(ChannelReader<T> channel, CancellationToken cancellationToken = default) 34private readonly ChannelReader<T> _channel; 36public ChannelAsyncEnumerator(ChannelReader<T> channel, CancellationToken cancellationToken) 201private static readonly MethodInfo _channelReaderTryReadMethodInfo = typeof(ChannelReader<>).GetMethod("TryRead")!; 202private static readonly MethodInfo _channelReaderWaitToReadAsyncMethodInfo = typeof(ChannelReader<>).GetMethod("WaitToReadAsync")!;

src\aspnetcore\src\SignalR\common\Shared\ReflectionHelper.cs (1)

33if (nullableType.IsGenericType && nullableType.GetGenericTypeDefinition() == typeof(ChannelReader<>))

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

20public static async IAsyncEnumerable<T> ReadAllAsync<T>(this ChannelReader<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

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

20public static async IAsyncEnumerable<T> ReadAllAsync<T>(this ChannelReader<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

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

20public static async IAsyncEnumerable<T> ReadAllAsync<T>(this ChannelReader<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

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

20public static async IAsyncEnumerable<T> ReadAllAsync<T>(this ChannelReader<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

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

17public static IAsyncEnumerable<T> ReadAllAsync<T>(ChannelReader<T> reader, CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

166ChannelReader<ChatResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)

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

20public static async IAsyncEnumerable<T> ReadAllAsync<T>(this ChannelReader<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)

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

24ChannelReader<TItem> reader, 226Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems, 322Func<ChannelReader<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,

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

592/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary> 617/// <summary>Represents a waiting reader from <see cref="ChannelReader{T}.WaitToReadAsync"/>.</summary>

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

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

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

23/// <summary>Gets whether <see cref="Count"/> is available for use on this <see cref="ChannelReader{T}"/> instance.</summary> 26/// <summary>Gets whether <see cref="TryPeek"/> is available for use on this <see cref="ChannelReader{T}"/> instance.</summary>