ChannelReader

HubConnectionHandlerTestUtils\Hubs.cs (1)

871public class AsyncEnumerableImplChannelThrows<T> : ChannelReader<T>, IAsyncEnumerable<T>

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>

MetricsChannel.cs (1)

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

Devcontainers\DevcontainerSettingsWriter.cs (1)

69var reader = _portUpdates.Reader;

Pipelines\DistributedApplicationPipelineTests.cs (6)

884var activityReader = reporter.ActivityItemUpdated.Reader; 925var activityReader = reporter.ActivityItemUpdated.Reader; 973var activityReader = reporter.ActivityItemUpdated.Reader; 1016var activityReader = reporter.ActivityItemUpdated.Reader; 1057var activityReader = reporter.ActivityItemUpdated.Reader; 1101var activityReader = reporter.ActivityItemUpdated.Reader;

Publishing\PublishingActivityReporterTests.cs (18)

StreamingSample.cs (1)

33var reader = await connection.StreamAsChannelAsync<int>("ChannelCounter", 10, 2000);

UploadSample.cs (1)

95var outputs = await connection.StreamAsChannelAsync<string>("StreamEcho", channel.Reader);

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

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

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\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

91internal ChannelReader<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader; 110var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader;

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

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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,

TestWebSocketConnectionFeature.cs (2)

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

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

91internal ChannelReader<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader; 110var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader;

HubConnection.cs (8)

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

HubConnectionExtensions.StreamAsChannelAsync.cs (26)

Internal\InvocationRequest.cs (2)

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

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\SignalR\common\Shared\ReflectionHelper.cs (1)

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

HubConnectionTests.cs (11)

Hubs.cs (28)

HubConnectionTests.cs (1)

853.Returns(() => Task.FromResult(It.IsAny<ChannelReader<object>>()));

HubConnectionTests.Protocol.cs (6)

209var channel = await hubConnection.StreamAsChannelAsync<object>("Foo").DefaultTimeout(); 258var channel = await hubConnection.StreamAsChannelAsync<int>("Foo").DefaultTimeout(); 325var channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout(); 348var channel = await hubConnection.StreamAsChannelAsync<int>("Foo").DefaultTimeout(); 394var channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout(); 423var channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout();

HubConnectionTests.Tracing.cs (1)

78var channel = await hubConnection.StreamAsChannelAsync<object>("Foo").DefaultTimeout();

HubServerProxy.GeneratedIMyHub.g.cs (8)

HubServerProxyGeneratorTests.cs (14)

36Task<ChannelReader<int>> StreamToClientViaChannel(); 37Task<ChannelReader<int>> StreamToClientViaChannelWithToken(CancellationToken cancellationToken); 39Task StreamFromClientViaChannel(ChannelReader<int> reader); 41Task<int> StreamFromClientButAlsoReturnValue(ChannelReader<int> reader); 42Task<ChannelReader<int>> StreamBidirectionalViaChannel(ChannelReader<float> reader); 43Task<ChannelReader<int>> StreamBidirectionalViaChannelWithToken(ChannelReader<float> reader, CancellationToken cancellationToken); 217var channelReader = channel.Reader; 224It.Is<object[]>(y => ((object[])y).Any(z => (ChannelReader<int>)z == channelReader)), 237It.Is<object[]>(y => ((object[])y).Any(z => (ChannelReader<int>)z == channelReader)), 259var retChannelReader = retChannel.Reader; 271It.Is<object[]>(y => ((object[])y).Any(z => z is ChannelReader<float>)), 278It.Is<object[]>(y => ((object[])y).Any(z => z is ChannelReader<float>)),

Internal\HubMethodDescriptor.cs (1)

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

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\SignalR\common\Shared\ReflectionHelper.cs (1)

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

DefaultHubDispatcherBenchmark.cs (7)

134public ChannelReader<int> StreamChannelReader() 142public Task<ChannelReader<int>> StreamChannelReaderAsync() 147return Task.FromResult<ChannelReader<int>>(channel); 150public ValueTask<ChannelReader<int>> StreamChannelReaderValueTaskAsync() 155return new ValueTask<ChannelReader<int>>(channel); 158public ChannelReader<int> StreamChannelReaderCount(int count) 194public async Task UploadStream(ChannelReader<string> channelReader)

HubConnectionHandlerTestUtils\Hubs.cs (39)

Internal\ReflectionHelperTests.cs (1)

32typeof(ChannelReader<object>),

NativeAotTests.cs (7)

80var echoResponseReader = await connection.StreamAsChannelAsync<string>(nameof(AsyncMethodHub.StreamEcho), channel.Reader); 100var returnChannelValueTypeReader = await connection.StreamAsChannelAsync<char>(nameof(AsyncMethodHub.ReturnChannelValueType), "Hello"); 247public ChannelReader<string> StreamEcho(ChannelReader<string> source) 280public ChannelReader<char> ReturnChannelValueType(string source) 321public async Task<string> ChannelShortParameter(ChannelReader<object> source) 345public async Task StreamValueType(ILogger<ChannelValueTypeMethodHub> logger, ChannelReader<double> source)

ChannelExtensions.cs (2)

10public static async Task<List<T>> ReadAndCollectAllAsync<T>(this ChannelReader<T> channel, bool suppressExceptions = false) 37public static async Task<List<T>> ReadAtLeastAsync<T>(this ChannelReader<T> reader, int minimumCount, CancellationToken cancellationToken = default)

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

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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,

ChannelReaderExtensions.cs (1)

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

ProducerConsumer.cs (3)

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

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

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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,

TestHub.cs (5)

60public ChannelReader<string> Stream() 70public ChannelReader<string> InfiniteStream(CancellationToken token) 83public async Task<string> StreamingConcat(ChannelReader<string> stream) 98public ChannelReader<int> EmptyStream() 105public ChannelReader<string> StreamThrowException(string message)

Hubs\Streaming.cs (2)

21public ChannelReader<int> ObservableCounter(int count, double delay) 30public ChannelReader<int> ChannelCounter(int count, double delay)

Hubs\UploadHub.cs (6)

19public async Task<string> UploadWord(ChannelReader<string> source) 38public async Task<string> ScoreTracker(ChannelReader<int> player1, ChannelReader<int> player2) 46async Task<int> Loop(ChannelReader<int> reader) 63public ChannelReader<string> StreamEcho(ChannelReader<string> source)

ObservableExtensions.cs (1)

11public static ChannelReader<T> AsChannelReader<T>(

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

555/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary> 580/// <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>

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

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

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\Dependencies\Threading\ChannelReaderExtensions.cs (1)

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

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,