6 types derived from ChannelReader
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTestUtils\Hubs.cs (1)
871
public class AsyncEnumerableImplChannelThrows<T> :
ChannelReader
<T>, IAsyncEnumerable<T>
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
70
private sealed class BoundedChannelReader :
ChannelReader
<T>, IDebugEnumerable<T>
System\Threading\Channels\RendezvousChannel.cs (1)
60
private sealed class RendezvousChannelReader :
ChannelReader
<T>
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
53
private sealed class UnboundedChannelReader :
ChannelReader
<T>, IDebugEnumerable<T>
System\Threading\Channels\UnboundedChannel.cs (1)
47
private sealed class UnboundedChannelReader :
ChannelReader
<T>, IDebugEnumerable<T>
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
54
private sealed class UnboundedPrioritizedChannelReader :
ChannelReader
<T>, IDebugEnumerable<T>
249 references to ChannelReader
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
23
public
ChannelReader
<string> Reader => _channel.Reader;
ClientSample (2)
StreamingSample.cs (1)
33
var
reader = await connection.StreamAsChannelAsync<int>("ChannelCounter", 10, 2000);
UploadSample.cs (1)
95
var
outputs = await connection.StreamAsChannelAsync<string>("StreamEcho", channel.Reader);
GenerateDocumentationAndConfigFiles (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
91
internal
ChannelReader
<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader;
110
var
reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader;
Metrics (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Metrics.Legacy (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.AspNetCore.Http.Connections.Tests (2)
TestWebSocketConnectionFeature.cs (2)
59
private readonly
ChannelReader
<WebSocketMessage> _input;
68
public WebSocketChannel(
ChannelReader
<WebSocketMessage> input, ChannelWriter<WebSocketMessage> output, SyncPoint sync = null)
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
91
internal
ChannelReader
<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader;
110
var
reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader;
Microsoft.AspNetCore.SignalR.Client.Core (40)
HubConnection.cs (8)
429
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
434
public virtual async Task<
ChannelReader
<object?>> StreamAsChannelCoreAsync(string methodName, Type returnType, object?[] args, CancellationToken cancellationToken = default)
682
var
reader = await StreamAsChannelCoreAsync(methodName, typeof(T), args, cts.Token).ConfigureAwait(false);
701
private async Task<
ChannelReader
<object?>> StreamAsChannelCoreAsyncCore(string methodName, Type returnType, object?[] args, CancellationToken cancellationToken)
740
ChannelReader
<object?> channel;
868
throw new InvalidOperationException($"{reader.GetType()} is not a {typeof(
ChannelReader
<>).Name}.");
937
private Task SendStreamItems<T>(ConnectionState connectionState, string streamId,
ChannelReader
<T> reader, CancellationTokenSource tokenSource)
1616
async Task StartProcessingInvocationMessages(
ChannelReader
<InvocationMessage> invocationMessageChannelReader)
HubConnectionExtensions.StreamAsChannelAsync.cs (26)
27
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
30
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, CancellationToken cancellationToken = default)
45
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
48
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, CancellationToken cancellationToken = default)
64
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
67
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, CancellationToken cancellationToken = default)
84
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
87
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, CancellationToken cancellationToken = default)
105
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
108
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, CancellationToken cancellationToken = default)
127
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
130
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, CancellationToken cancellationToken = default)
150
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
153
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, object? arg6, CancellationToken cancellationToken = default)
174
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
177
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, object? arg6, object? arg7, CancellationToken cancellationToken = default)
199
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
202
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, object? arg6, object? arg7, object? arg8, CancellationToken cancellationToken = default)
225
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
228
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, object? arg6, object? arg7, object? arg8, object? arg9, CancellationToken cancellationToken = default)
252
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
255
public static Task<
ChannelReader
<TResult>> StreamAsChannelAsync<TResult>(this HubConnection hubConnection, string methodName, object? arg1, object? arg2, object? arg3, object? arg4, object? arg5, object? arg6, object? arg7, object? arg8, object? arg9, object? arg10, CancellationToken cancellationToken = default)
270
/// The <see cref="Task{TResult}.Result"/> property returns a <see cref="
ChannelReader
{T}"/> for the streamed hub method values.
272
public static async Task<
ChannelReader
<TResult>> StreamAsChannelCoreAsync<TResult>(this HubConnection hubConnection, string methodName, object?[] args, CancellationToken cancellationToken = default)
276
var
inputChannel = await hubConnection.StreamAsChannelCoreAsync(methodName, typeof(TResult), args, cancellationToken).ConfigureAwait(false);
287
private static async Task RunChannel<TResult>(
ChannelReader
<object?> inputChannel, Channel<TResult> outputChannel)
Internal\InvocationRequest.cs (2)
56
ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out
ChannelReader
<object?> result)
88
public
ChannelReader
<object?> Result => _channel.Reader;
src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (3)
27
public static IAsyncEnumerator<object?> MakeAsyncEnumeratorFromChannel<T>(
ChannelReader
<T> channel, CancellationToken cancellationToken = default)
34
private readonly
ChannelReader
<T> _channel;
36
public ChannelAsyncEnumerator(
ChannelReader
<T> channel, CancellationToken cancellationToken)
src\SignalR\common\Shared\ReflectionHelper.cs (1)
33
if (nullableType.IsGenericType && nullableType.GetGenericTypeDefinition() == typeof(
ChannelReader
<>))
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (39)
HubConnectionTests.cs (11)
769
var
channel = await connection.StreamAsChannelAsync<int>("Stream", 5).DefaultTimeout();
800
var
channel = await connection.StreamAsChannelAsync<string>("StreamEcho", channelWriter.Reader).DefaultTimeout();
848
var
channel = await connection.StreamAsChannelAsync<string>("StreamEcho", stream).DefaultTimeout();
896
var
channel = await connection.StreamAsChannelAsync<int>("StreamEchoInt", stream, cts.Token).DefaultTimeout();
979
var
channel = await connection.StreamAsChannelAsync<int>("Stream", 1000, cts.Token).DefaultTimeout();
1052
var
channel = await connection.StreamAsChannelAsync<int>("StreamException").DefaultTimeout();
1189
var
channel = await connection.StreamAsChannelAsync<int>("!@#$%");
1217
var
channel = await connection.StreamAsChannelAsync<int>("Stream", 42, 42);
1245
var
channel = await connection.StreamAsChannelAsync<int>("Stream", "xyz");
1272
var
channel = await connection.StreamAsChannelAsync<int>("HelloWorld").DefaultTimeout();
1326
var
channel = await connection.StreamAsChannelAsync<int>("StreamBroken").DefaultTimeout();
Hubs.cs (28)
25
public
ChannelReader
<int> Stream(int count) => TestHubMethodsImpl.Stream(count);
27
public
ChannelReader
<int> StreamException() => TestHubMethodsImpl.StreamException();
29
public
ChannelReader
<string> StreamBroken() => TestHubMethodsImpl.StreamBroken();
46
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source) => TestHubMethodsImpl.StreamEcho(source);
48
public
ChannelReader
<int> StreamEchoInt(
ChannelReader
<int> source) => TestHubMethodsImpl.StreamEchoInt(source);
147
public
ChannelReader
<int> Stream(int count) => TestHubMethodsImpl.Stream(count);
149
public
ChannelReader
<int> StreamException() => TestHubMethodsImpl.StreamException();
151
public
ChannelReader
<string> StreamBroken() => TestHubMethodsImpl.StreamBroken();
168
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source) => TestHubMethodsImpl.StreamEcho(source);
170
public
ChannelReader
<int> StreamEchoInt(
ChannelReader
<int> source) => TestHubMethodsImpl.StreamEchoInt(source);
183
public
ChannelReader
<int> Stream(int count) => TestHubMethodsImpl.Stream(count);
185
public
ChannelReader
<int> StreamException() => TestHubMethodsImpl.StreamException();
187
public
ChannelReader
<string> StreamBroken() => TestHubMethodsImpl.StreamBroken();
204
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source) => TestHubMethodsImpl.StreamEcho(source);
206
public
ChannelReader
<int> StreamEchoInt(
ChannelReader
<int> source) => TestHubMethodsImpl.StreamEchoInt(source);
225
public static
ChannelReader
<int> Stream(int count)
243
public static
ChannelReader
<int> StreamException()
248
public static
ChannelReader
<string> StreamBroken() => null;
250
public static
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source)
274
public static
ChannelReader
<int> StreamEchoInt(
ChannelReader
<int> source)
Microsoft.AspNetCore.SignalR.Client.Tests (22)
HubConnectionTests.cs (1)
853
.Returns(() => Task.FromResult(It.IsAny<
ChannelReader
<object>>()));
HubConnectionTests.Protocol.cs (6)
209
var
channel = await hubConnection.StreamAsChannelAsync<object>("Foo").DefaultTimeout();
258
var
channel = await hubConnection.StreamAsChannelAsync<int>("Foo").DefaultTimeout();
325
var
channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout();
348
var
channel = await hubConnection.StreamAsChannelAsync<int>("Foo").DefaultTimeout();
394
var
channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout();
423
var
channel = await hubConnection.StreamAsChannelAsync<string>("Foo").DefaultTimeout();
HubConnectionTests.Tracing.cs (1)
78
var
channel = await hubConnection.StreamAsChannelAsync<object>("Foo").DefaultTimeout();
HubServerProxyGeneratorTests.cs (14)
36
Task<
ChannelReader
<int>> StreamToClientViaChannel();
37
Task<
ChannelReader
<int>> StreamToClientViaChannelWithToken(CancellationToken cancellationToken);
39
Task StreamFromClientViaChannel(
ChannelReader
<int> reader);
41
Task<int> StreamFromClientButAlsoReturnValue(
ChannelReader
<int> reader);
42
Task<
ChannelReader
<int>> StreamBidirectionalViaChannel(
ChannelReader
<float> reader);
43
Task<
ChannelReader
<int>> StreamBidirectionalViaChannelWithToken(
ChannelReader
<float> reader, CancellationToken cancellationToken);
217
var
channelReader = channel.Reader;
224
It.Is<object[]>(y => ((object[])y).Any(z => (
ChannelReader
<int>)z == channelReader)),
237
It.Is<object[]>(y => ((object[])y).Any(z => (
ChannelReader
<int>)z == channelReader)),
259
var
retChannelReader = retChannel.Reader;
271
It.Is<object[]>(y => ((object[])y).Any(z => z is
ChannelReader
<float>)),
278
It.Is<object[]>(y => ((object[])y).Any(z => z is
ChannelReader
<float>)),
Microsoft.AspNetCore.SignalR.Core (7)
Internal\HubMethodDescriptor.cs (1)
51
if (returnType.IsGenericType && returnType.GetGenericTypeDefinition() == typeof(
ChannelReader
<>))
src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (5)
27
public static IAsyncEnumerator<object?> MakeAsyncEnumeratorFromChannel<T>(
ChannelReader
<T> channel, CancellationToken cancellationToken = default)
34
private readonly
ChannelReader
<T> _channel;
36
public ChannelAsyncEnumerator(
ChannelReader
<T> channel, CancellationToken cancellationToken)
201
private static readonly MethodInfo _channelReaderTryReadMethodInfo = typeof(
ChannelReader
<>).GetMethod("TryRead")!;
202
private static readonly MethodInfo _channelReaderWaitToReadAsyncMethodInfo = typeof(
ChannelReader
<>).GetMethod("WaitToReadAsync")!;
src\SignalR\common\Shared\ReflectionHelper.cs (1)
33
if (nullableType.IsGenericType && nullableType.GetGenericTypeDefinition() == typeof(
ChannelReader
<>))
Microsoft.AspNetCore.SignalR.Microbenchmarks (7)
DefaultHubDispatcherBenchmark.cs (7)
134
public
ChannelReader
<int> StreamChannelReader()
142
public Task<
ChannelReader
<int>> StreamChannelReaderAsync()
147
return Task.FromResult<
ChannelReader
<int>>(channel);
150
public ValueTask<
ChannelReader
<int>> StreamChannelReaderValueTaskAsync()
155
return new ValueTask<
ChannelReader
<int>>(channel);
158
public
ChannelReader
<int> StreamChannelReaderCount(int count)
194
public async Task UploadStream(
ChannelReader
<string> channelReader)
Microsoft.AspNetCore.SignalR.Tests (47)
HubConnectionHandlerTestUtils\Hubs.cs (39)
191
public async Task<string> StreamingConcat(
ChannelReader
<string> source)
206
public async Task StreamDontRead(
ChannelReader
<string> source)
213
public async Task<int> StreamingSum(
ChannelReader
<int> source)
226
public async Task<List<object>> UploadArray(
ChannelReader
<object> source)
242
public async Task<List<object>> UploadArrayAuth(
ChannelReader
<object> source)
257
public async Task<string> TestTypeCastingErrors(
ChannelReader
<int> source)
271
public async Task<bool> TestCustomErrorPassing(
ChannelReader
<int> source)
285
public Task UploadIgnoreItems(
ChannelReader
<string> source)
291
public
ChannelReader
<string> StreamAndUploadIgnoreItems(
ChannelReader
<string> source)
298
async Task ChannelFunc(ChannelWriter<string> output,
ChannelReader
<string> input)
306
public async Task UploadDoesWorkOnComplete(
ChannelReader
<string> source)
362
public async Task<int> GetClientResultWithStream(
ChannelReader
<int> channelReader)
702
public
ChannelReader
<string> CounterChannel(int count)
718
public async Task<
ChannelReader
<string>> CounterChannelAsync(int count)
725
public async Task<
ChannelReader
<string>> CounterChannelAsync2(int count)
731
public async ValueTask<
ChannelReader
<string>> CounterChannelValueTaskAsync(int count)
771
public
ChannelReader
<string> BlockingStream()
776
public
ChannelReader
<int> ExceptionStream()
783
public
ChannelReader
<int> ChannelClosedExceptionStream()
790
public
ChannelReader
<int> ChannelClosedExceptionInnerExceptionStream()
797
public
ChannelReader
<int> ThrowStream()
802
public
ChannelReader
<int> NullStream()
812
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source)
873
private readonly
ChannelReader
<T> _inner;
875
public AsyncEnumerableImplChannelThrows(
ChannelReader
<T> inner)
901
private readonly
ChannelReader
<T> _channel;
907
public ChannelAsyncEnumerator(
ChannelReader
<T> channel, CancellationToken cancellationToken)
1025
public async Task<
ChannelReader
<string>> LongRunningStream()
1033
public
ChannelReader
<int> CancelableStreamSingleParameter(CancellationToken token)
1048
public
ChannelReader
<int> CancelableStreamMultiParameter(int ignore, int ignore2, CancellationToken token)
1063
public
ChannelReader
<int> CancelableStreamNullableParameter(int x, string y, CancellationToken token)
1078
public
ChannelReader
<int> StreamNullableParameter(int x, int? input)
1093
public
ChannelReader
<int> CancelableStreamMiddleParameter(int ignore, CancellationToken token, int ignore2)
1129
public
ChannelReader
<int> CountingCancelableStreamGeneratedChannel(int count, CancellationToken token)
1159
public async Task Upload(
ChannelReader
<string> stream)
1375
public async Task<int> ServicesAndParams(int value, [FromService] Service1 service,
ChannelReader
<int> channelReader, [FromService] Service2 service2, bool value2)
1405
public async Task Stream(
ChannelReader
<int> channelReader)
Internal\ReflectionHelperTests.cs (1)
32
typeof(
ChannelReader
<object>),
NativeAotTests.cs (7)
80
var
echoResponseReader = await connection.StreamAsChannelAsync<string>(nameof(AsyncMethodHub.StreamEcho), channel.Reader);
100
var
returnChannelValueTypeReader = await connection.StreamAsChannelAsync<char>(nameof(AsyncMethodHub.ReturnChannelValueType), "Hello");
247
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source)
280
public
ChannelReader
<char> ReturnChannelValueType(string source)
321
public async Task<string> ChannelShortParameter(
ChannelReader
<object> source)
345
public async Task StreamValueType(ILogger<ChannelValueTypeMethodHub> logger,
ChannelReader
<double> source)
Microsoft.AspNetCore.SignalR.Tests.Utils (2)
ChannelExtensions.cs (2)
10
public static async Task<List<T>> ReadAndCollectAllAsync<T>(this
ChannelReader
<T> channel, bool suppressExceptions = false)
37
public static async Task<List<T>> ReadAtLeastAsync<T>(this
ChannelReader
<T> reader, int minimumCount, CancellationToken cancellationToken = default)
Microsoft.CodeAnalysis.Analyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.AnalyzerUtilities (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.BannedApiAnalyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.CodeStyle (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.PublicApiAnalyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.ResxSourceGenerator (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Microsoft.CodeAnalysis.Workspaces (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Roslyn.Diagnostics.Analyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
SignalR.Client.FunctionalTestApp (5)
TestHub.cs (5)
60
public
ChannelReader
<string> Stream()
70
public
ChannelReader
<string> InfiniteStream(CancellationToken token)
83
public async Task<string> StreamingConcat(
ChannelReader
<string> stream)
98
public
ChannelReader
<int> EmptyStream()
105
public
ChannelReader
<string> StreamThrowException(string message)
SignalRSamples (9)
Hubs\Streaming.cs (2)
21
public
ChannelReader
<int> ObservableCounter(int count, double delay)
30
public
ChannelReader
<int> ChannelCounter(int count, double delay)
Hubs\UploadHub.cs (6)
19
public async Task<string> UploadWord(
ChannelReader
<string> source)
38
public async Task<string> ScoreTracker(
ChannelReader
<int> player1,
ChannelReader
<int> player2)
46
async Task<int> Loop(
ChannelReader
<int> reader)
63
public
ChannelReader
<string> StreamEcho(
ChannelReader
<string> source)
ObservableExtensions.cs (1)
11
public static
ChannelReader
<T> AsChannelReader<T>(
System.Threading.Channels (6)
System\Threading\Channels\AsyncOperation.cs (2)
556
/// <summary>Represents a blocked reader from <see cref="
ChannelReader
{T}.ReadAsync"/>.</summary>
581
/// <summary>Represents a waiting reader from <see cref="
ChannelReader
{T}.WaitToReadAsync"/>.</summary>
System\Threading\Channels\Channel_2.cs (2)
15
public
ChannelReader
<TRead> Reader { get; protected set; } = null!; // derived types should always set the Reader as part of construction
22
public 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>
Test.Utilities (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
Text.Analyzers (4)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
82
this
ChannelReader
<T> reader, [EnumeratorCancellation] CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)
41
ChannelReader
<TItem> reader,
243
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,
339
Func<
ChannelReader
<TItem>, TArgs, CancellationToken, Task<TResult>> consumeItems,