CreateUnbounded

Hosting\CliOrphanDetectorTests.cs (3)

40var stopSignalChannel = Channel.CreateUnbounded<bool>(); 61var stopSignalChannel = Channel.CreateUnbounded<bool>(); 62var processRunningChannel = Channel.CreateUnbounded<int>();

ActivityNotifier.cs (1)

16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>();

Pages\ConsoleLogsTests.cs (17)

Pages\ResourcesTests.cs (4)

36var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 135var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 187var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 223resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>);

tests\Shared\TestDashboardTelemetrySender.cs (1)

12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();

ChannelExtensionsTests.cs (6)

19var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 43var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 67var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 68var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>(); 111var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 112var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>();

Integration\DashboardClientAuthTests.cs (1)

157public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ApplicationInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();

ResourceOutgoingPeerResolverTests.cs (2)

124var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 125var resultChannel = Channel.CreateUnbounded<int>();

TelemetryRepositoryTests\LogTests.cs (1)

712var resultChannel = Channel.CreateUnbounded<int>();

tests\Shared\TestDashboardTelemetrySender.cs (1)

12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();

ApplicationModel\ResourceLoggerService.cs (3)

223var channel = Channel.CreateUnbounded<LogSubscriber>(); 297var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 419var channel = Channel.CreateUnbounded<LogEntry>();

ApplicationModel\ResourceNotificationService.cs (1)

439var channel = Channel.CreateUnbounded<ResourceEvent>();

Publishing\PublishingActivityProgressReporter.cs (1)

159internal Channel<PublishingActivityStatus> ActivityStatusUpdated { get; } = Channel.CreateUnbounded<PublishingActivityStatus>();

Dashboard\DashboardLifecycleHookTests.cs (1)

39var logChannel = Channel.CreateUnbounded<WriteContext>();

Dashboard\DashboardServiceTests.cs (1)

33var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();

Dcp\DcpExecutorTests.cs (2)

71var channel = Channel.CreateUnbounded<string>(); 568var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>();

Dcp\TestKubernetesService.cs (1)

134var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();

DistributedApplicationTests.cs (1)

523var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>();

Health\ResourceHealthCheckServiceTests.cs (2)

151var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 294var channel = Channel.CreateUnbounded<DateTimeOffset>();

ResourceLoggerServiceTests.cs (2)

262var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 266var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();

Utils\Grpc\TestAsyncStreamReader.cs (1)

18_channel = Channel.CreateUnbounded<T>();

Utils\Grpc\TestServerStreamWriter.cs (1)

18_channel = Channel.CreateUnbounded<T>();

UploadSample.cs (2)

44var channel = Channel.CreateUnbounded<string>(); 85var channel = Channel.CreateUnbounded<string>();

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

46_serverReceivedSettings = Channel.CreateUnbounded<KeyValuePair<Http3SettingType, long>>();

TestTransport\InMemoryTransportFactory.cs (1)

15private readonly Channel<ConnectionContext> _acceptQueue = Channel.CreateUnbounded<ConnectionContext>();

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

33_counters[item] = Channel.CreateUnbounded<double>();

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

33_counters[item] = Channel.CreateUnbounded<double>();

TestWebSocketConnectionFeature.cs (2)

40var clientToServer = Channel.CreateUnbounded<WebSocketMessage>(); 41var serverToClient = Channel.CreateUnbounded<WebSocketMessage>();

Internal\WebTransport\WebTransportSession.cs (1)

52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();

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

46_serverReceivedSettings = Channel.CreateUnbounded<KeyValuePair<Http3SettingType, long>>();

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

277var outputChannel = Channel.CreateUnbounded<TResult>();

Internal\InvocationRequest.cs (1)

81private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();

HubConnectionTests.cs (1)

2925private readonly Channel<(SendOrPostCallback, object)> _taskQueue = Channel.CreateUnbounded<(SendOrPostCallback, object)>();

HubConnectionTests.Tracing.cs (7)

35var serverChannel = Channel.CreateUnbounded<Activity>(); 36var clientChannel = Channel.CreateUnbounded<Activity>(); 229var serverChannel = Channel.CreateUnbounded<Activity>(); 374var serverChannel = Channel.CreateUnbounded<Activity>(); 477var serverChannel = Channel.CreateUnbounded<Activity>(); 573var serverChannel = Channel.CreateUnbounded<Activity>(); 663var serverChannel = Channel.CreateUnbounded<Activity>();

Hubs.cs (3)

227var channel = Channel.CreateUnbounded<int>(); 252var output = Channel.CreateUnbounded<string>(); 276var output = Channel.CreateUnbounded<int>();

HubConnectionTests.cs (8)

438var channel = Channel.CreateUnbounded<int>(); 478var channel = Channel.CreateUnbounded<int>(); 509var channel = Channel.CreateUnbounded<object>(); 554var channel = Channel.CreateUnbounded<int>(); 586var channel = Channel.CreateUnbounded<int>(); 611var channel = Channel.CreateUnbounded<int>(); 645var channel = Channel.CreateUnbounded<int>(); 678var channel = Channel.CreateUnbounded<int>();

HubServerProxyGeneratorTests.cs (8)

174var channel = Channel.CreateUnbounded<object>(); 175var channelForEnumerable = Channel.CreateUnbounded<int>(); 216var channel = Channel.CreateUnbounded<int>(); 218var channelForEnumerable = Channel.CreateUnbounded<int>(); 257var argChannel = Channel.CreateUnbounded<float>(); 258var retChannel = Channel.CreateUnbounded<object>(); 260var argChannelForEnumerable = Channel.CreateUnbounded<float>(); 262var retChannelForEnumerable = Channel.CreateUnbounded<int>();

DefaultHubDispatcherBenchmark.cs (4)

136var channel = Channel.CreateUnbounded<int>(); 144var channel = Channel.CreateUnbounded<int>(); 152var channel = Channel.CreateUnbounded<int>(); 160var channel = Channel.CreateUnbounded<int>();

HubConnectionHandlerTests.Activity.cs (8)

HubConnectionHandlerTestUtils\Hubs.cs (8)

293var channel = Channel.CreateUnbounded<string>(); 704var channel = Channel.CreateUnbounded<string>(); 773return Channel.CreateUnbounded<string>().Reader; 778var channel = Channel.CreateUnbounded<int>(); 785var channel = Channel.CreateUnbounded<int>(); 792var channel = Channel.CreateUnbounded<int>(); 814Channel<string> output = Channel.CreateUnbounded<string>(); 1030return Channel.CreateUnbounded<string>().Reader;

NativeAotTests.cs (2)

249Channel<string> output = Channel.CreateUnbounded<string>(); 282Channel<char> output = Channel.CreateUnbounded<char>();

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

271var channel = Channel.CreateUnbounded<TItem>();

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

271var channel = Channel.CreateUnbounded<TItem>();

ServiceEndpointResolverTests.cs (1)

264var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();

TestHub.cs (3)

62var channel = Channel.CreateUnbounded<string>(); 72var channel = Channel.CreateUnbounded<string>(); 100var channel = Channel.CreateUnbounded<int>();

Hubs\Streaming.cs (1)

32var channel = Channel.CreateUnbounded<int>();

Hubs\UploadHub.cs (1)

65var output = Channel.CreateUnbounded<string>();

ObservableExtensions.cs (1)

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

ProducerConsumer.cs (1)

20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();

Program.cs (1)

162var channel = Channel.CreateUnbounded<string>();

System\Net\Quic\QuicListener.cs (1)

141_acceptQueue = Channel.CreateUnbounded<object>();

Program.cs (1)

119_channel = Channel.CreateUnbounded<string>();