CreateBounded

30 references to CreateBounded

ClientSample (2)

UploadSample.cs (2)

60var channel_one = Channel.CreateBounded<int>(2); 61var channel_two = Channel.CreateBounded<int>(2);

GenerateDocumentationAndConfigFiles (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Metrics (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Metrics.Legacy (1)

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

59var channel = Channel.CreateBounded<T>(1024);

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)

4749var 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.Analyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.BannedApiAnalyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.CodeStyle (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.PublicApiAnalyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Microsoft.CodeAnalysis.ResxSourceGenerator (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)

136var updates = Channel.CreateBounded<ChatResponseUpdate>(1);

Roslyn.Diagnostics.Analyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);

SignalRSamples (1)

ObservableExtensions.cs (1)

26var channel = maxBufferSize != null ? Channel.CreateBounded<T>(maxBufferSize.Value) : Channel.CreateUnbounded<T>();

Test.Utilities (1)

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

59var channel = Channel.CreateBounded<T>(1024);

Text.Analyzers (1)

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

59var channel = Channel.CreateBounded<T>(1024);