18 references to CreateBounded
ClientSample (2)
UploadSample.cs (2)
60var channel_one = Channel.CreateBounded<int>(2); 61var channel_two = Channel.CreateBounded<int>(2);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (1)
HubConnectionTests.cs (1)
799var channelWriter = Channel.CreateBounded<string>(5);
Microsoft.AspNetCore.SignalR.Core (2)
Internal\ChannelBasedSemaphore.cs (1)
17_channel = Channel.CreateBounded<int>(maxCapacity);
StreamTracker.cs (1)
112_channel = Channel.CreateBounded<T?>(streamBufferCapacity);
Microsoft.AspNetCore.SignalR.Tests (9)
HubConnectionHandlerTests.cs (1)
4731var channel = Channel.CreateBounded<int>(10);
HubConnectionHandlerTestUtils\Hubs.cs (6)
1035var channel = Channel.CreateBounded<int>(10); 1050var channel = Channel.CreateBounded<int>(10); 1065var channel = Channel.CreateBounded<int>(10); 1080var channel = Channel.CreateBounded<int>(10); 1095var channel = Channel.CreateBounded<int>(10); 1131var channel = Channel.CreateBounded<int>(10);
NativeAotTests.cs (2)
79var channel = Channel.CreateBounded<string>(10); 112var channelShorts = Channel.CreateBounded<short>(10);
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
59var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
59var channel = Channel.CreateBounded<T>(1024);
Microsoft.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
130var updates = Channel.CreateBounded<StreamingChatCompletionUpdate>(1);
SignalRSamples (1)
ObservableExtensions.cs (1)
26var channel = maxBufferSize != null ? Channel.CreateBounded<T>(maxBufferSize.Value) : Channel.CreateUnbounded<T>();