163 references to CreateUnbounded
Aspire.Cli.Tests (3)
Hosting\CliOrphanDetectorTests.cs (3)
39
var stopSignalChannel = Channel.
CreateUnbounded
<bool>();
60
var stopSignalChannel = Channel.
CreateUnbounded
<bool>();
61
var processRunningChannel = Channel.
CreateUnbounded
<int>();
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
16
private readonly Channel<Activity> _activityChannel = Channel.
CreateUnbounded
<Activity>();
Aspire.Dashboard (1)
ServiceClient\DashboardClient.cs (1)
51
private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.
CreateUnbounded
<WatchInteractionsRequestUpdate>();
Aspire.Dashboard.Components.Tests (38)
Interactions\InteractionsProviderTests.cs (7)
53
var interactionsChannel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>();
77
var interactionsChannel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>();
121
var interactionsChannel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>();
169
var interactionsChannel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>();
170
var sendInteractionUpdatesChannel = Channel.
CreateUnbounded
<WatchInteractionsRequestUpdate>();
225
var interactionsChannel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>();
226
var sendInteractionUpdatesChannel = Channel.
CreateUnbounded
<WatchInteractionsRequestUpdate>();
Pages\ConsoleLogsTests.cs (24)
45
var subscribedResourceNamesChannel = Channel.
CreateUnbounded
<string>();
46
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
47
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
95
var subscribedResourceNamesChannel = Channel.
CreateUnbounded
<string>();
96
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
97
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
156
consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
182
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
183
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
230
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
231
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
279
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
280
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
328
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
329
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
385
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
386
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
446
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
447
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
510
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
511
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
512
var resourceCommandChannel = Channel.
CreateUnbounded
<ResourceCommandResponseViewModel>();
569
var consoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>();
570
var resourceChannel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourcesTests.cs (5)
36
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
135
var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>);
187
var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>);
223
resourceChannelProvider: Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>);
318
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>();
Shared\ResourceSetupHelpers.cs (1)
116
context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>));
tests\Shared\TestDashboardTelemetrySender.cs (1)
12
public Channel<OperationContext> ContextChannel { get; } = Channel.
CreateUnbounded
<OperationContext>();
Aspire.Dashboard.Tests (11)
ChannelExtensionsTests.cs (6)
19
var channel = Channel.
CreateUnbounded
<IReadOnlyList<string>>();
43
var channel = Channel.
CreateUnbounded
<IReadOnlyList<string>>();
67
var channel = Channel.
CreateUnbounded
<IReadOnlyList<string>>();
68
var resultChannel = Channel.
CreateUnbounded
<IReadOnlyList<IReadOnlyList<string>>>();
111
var channel = Channel.
CreateUnbounded
<IReadOnlyList<string>>();
112
var resultChannel = Channel.
CreateUnbounded
<IReadOnlyList<IReadOnlyList<string>>>();
Integration\DashboardClientAuthTests.cs (1)
156
public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ApplicationInformationCallsChannel { get; } = Channel.
CreateUnbounded
<ReceivedCallInfo<ApplicationInformationRequest>>();
ResourceOutgoingPeerResolverTests.cs (2)
125
var sourceChannel = Channel.
CreateUnbounded
<ResourceViewModelChange>();
126
var resultChannel = Channel.
CreateUnbounded
<int>();
TelemetryRepositoryTests\LogTests.cs (1)
712
var resultChannel = Channel.
CreateUnbounded
<int>();
tests\Shared\TestDashboardTelemetrySender.cs (1)
12
public Channel<OperationContext> ContextChannel { get; } = Channel.
CreateUnbounded
<OperationContext>();
Aspire.Hosting (7)
ApplicationModel\InteractionService.cs (1)
220
var channel = Channel.
CreateUnbounded
<Interaction>();
ApplicationModel\ResourceLoggerService.cs (3)
223
var channel = Channel.
CreateUnbounded
<LogSubscriber>();
297
var channel = Channel.
CreateUnbounded
<IReadOnlyList<LogLine>>();
419
var channel = Channel.
CreateUnbounded
<LogEntry>();
ApplicationModel\ResourceNotificationService.cs (1)
460
var channel = Channel.
CreateUnbounded
<ResourceEvent>();
Backchannel\BackchannelLoggerProvider.cs (1)
12
private readonly Channel<BackchannelLogEntry> _channel = Channel.
CreateUnbounded
<BackchannelLogEntry>();
Publishing\PublishingActivityProgressReporter.cs (1)
710
internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.
CreateUnbounded
<PublishingActivity>();
Aspire.Hosting.Tests (16)
Dashboard\DashboardLifecycleHookTests.cs (1)
39
var logChannel = Channel.
CreateUnbounded
<WriteContext>();
Dashboard\DashboardServiceTests.cs (1)
35
var getConsoleLogsChannel = Channel.
CreateUnbounded
<IReadOnlyList<LogEntry>>();
Dcp\DcpExecutorTests.cs (2)
71
var channel = Channel.
CreateUnbounded
<string>();
568
var logStreamPipesChannel = Channel.
CreateUnbounded
<(string Type, Pipe Pipe)>();
Dcp\TestKubernetesService.cs (1)
134
var chan = Channel.
CreateUnbounded
<(WatchEventType, CustomResource)>();
DistributedApplicationTests.cs (1)
619
var beforeResourceStartedEvents = Channel.
CreateUnbounded
<BeforeResourceStartedEvent>();
Health\ResourceHealthCheckServiceTests.cs (2)
151
var channel = Channel.
CreateUnbounded
<ResourceReadyEvent>();
294
var channel = Channel.
CreateUnbounded
<DateTimeOffset>();
InteractionServiceTests.cs (1)
122
var updates = Channel.
CreateUnbounded
<Interaction>();
ResourceCommandServiceTests.cs (2)
59
var commandResourcesChannel = Channel.
CreateUnbounded
<string>();
88
commandResourcesChannel = Channel.
CreateUnbounded
<string>();
ResourceLoggerServiceTests.cs (2)
262
var consoleLogsChannel0 = Channel.
CreateUnbounded
<IReadOnlyList<LogEntry>>();
266
var 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>();
VersionChecking\VersionCheckServiceTests.cs (1)
240
public Channel<InteractionData> Interactions { get; } = Channel.
CreateUnbounded
<InteractionData>();
ClientSample (2)
UploadSample.cs (2)
44
var channel = Channel.
CreateUnbounded
<string>();
85
var channel = Channel.
CreateUnbounded
<string>();
GenerateDocumentationAndConfigFiles (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
45
_serverReceivedSettings = Channel.
CreateUnbounded
<KeyValuePair<Http3SettingType, long>>();
TestTransport\InMemoryTransportFactory.cs (1)
15
private readonly Channel<ConnectionContext> _acceptQueue = Channel.
CreateUnbounded
<ConnectionContext>();
Metrics (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Metrics.Legacy (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)
src\Shared\EventSource.Testing\TestCounterListener.cs (1)
33
_counters[item] = Channel.
CreateUnbounded
<double>();
Microsoft.AspNetCore.Hosting.Tests (1)
src\Shared\EventSource.Testing\TestCounterListener.cs (1)
33
_counters[item] = Channel.
CreateUnbounded
<double>();
Microsoft.AspNetCore.Http.Connections.Tests (2)
TestWebSocketConnectionFeature.cs (2)
40
var clientToServer = Channel.
CreateUnbounded
<WebSocketMessage>();
41
var serverToClient = Channel.
CreateUnbounded
<WebSocketMessage>();
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
52
_pendingStreams = Channel.
CreateUnbounded
<WebTransportStream>();
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
45
_serverReceivedSettings = Channel.
CreateUnbounded
<KeyValuePair<Http3SettingType, long>>();
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
277
var outputChannel = Channel.
CreateUnbounded
<TResult>();
Internal\InvocationRequest.cs (1)
81
private readonly Channel<object?> _channel = Channel.
CreateUnbounded
<object?>();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (11)
HubConnectionTests.cs (1)
2925
private readonly Channel<(SendOrPostCallback, object)> _taskQueue = Channel.
CreateUnbounded
<(SendOrPostCallback, object)>();
HubConnectionTests.Tracing.cs (7)
35
var serverChannel = Channel.
CreateUnbounded
<Activity>();
36
var clientChannel = Channel.
CreateUnbounded
<Activity>();
229
var serverChannel = Channel.
CreateUnbounded
<Activity>();
374
var serverChannel = Channel.
CreateUnbounded
<Activity>();
477
var serverChannel = Channel.
CreateUnbounded
<Activity>();
573
var serverChannel = Channel.
CreateUnbounded
<Activity>();
663
var serverChannel = Channel.
CreateUnbounded
<Activity>();
Hubs.cs (3)
227
var channel = Channel.
CreateUnbounded
<int>();
252
var output = Channel.
CreateUnbounded
<string>();
276
var output = Channel.
CreateUnbounded
<int>();
Microsoft.AspNetCore.SignalR.Client.Tests (16)
HubConnectionTests.cs (8)
438
var channel = Channel.
CreateUnbounded
<int>();
478
var channel = Channel.
CreateUnbounded
<int>();
509
var channel = Channel.
CreateUnbounded
<object>();
554
var channel = Channel.
CreateUnbounded
<int>();
586
var channel = Channel.
CreateUnbounded
<int>();
611
var channel = Channel.
CreateUnbounded
<int>();
645
var channel = Channel.
CreateUnbounded
<int>();
678
var channel = Channel.
CreateUnbounded
<int>();
HubServerProxyGeneratorTests.cs (8)
174
var channel = Channel.
CreateUnbounded
<object>();
175
var channelForEnumerable = Channel.
CreateUnbounded
<int>();
216
var channel = Channel.
CreateUnbounded
<int>();
218
var channelForEnumerable = Channel.
CreateUnbounded
<int>();
257
var argChannel = Channel.
CreateUnbounded
<float>();
258
var retChannel = Channel.
CreateUnbounded
<object>();
260
var argChannelForEnumerable = Channel.
CreateUnbounded
<float>();
262
var retChannelForEnumerable = Channel.
CreateUnbounded
<int>();
Microsoft.AspNetCore.SignalR.Microbenchmarks (4)
DefaultHubDispatcherBenchmark.cs (4)
136
var channel = Channel.
CreateUnbounded
<int>();
144
var channel = Channel.
CreateUnbounded
<int>();
152
var channel = Channel.
CreateUnbounded
<int>();
160
var channel = Channel.
CreateUnbounded
<int>();
Microsoft.AspNetCore.SignalR.Tests (18)
HubConnectionHandlerTests.Activity.cs (8)
22
var serverChannel = Channel.
CreateUnbounded
<Activity>();
97
var serverChannel = Channel.
CreateUnbounded
<Activity>();
169
var serverChannel = Channel.
CreateUnbounded
<Activity>();
228
var serverChannel = Channel.
CreateUnbounded
<Activity>();
301
var serverChannel = Channel.
CreateUnbounded
<Activity>();
348
var serverChannel = Channel.
CreateUnbounded
<Activity>();
400
var serverChannel = Channel.
CreateUnbounded
<Activity>();
451
var serverChannel = Channel.
CreateUnbounded
<Activity>();
HubConnectionHandlerTestUtils\Hubs.cs (8)
293
var channel = Channel.
CreateUnbounded
<string>();
704
var channel = Channel.
CreateUnbounded
<string>();
773
return Channel.
CreateUnbounded
<string>().Reader;
778
var channel = Channel.
CreateUnbounded
<int>();
785
var channel = Channel.
CreateUnbounded
<int>();
792
var channel = Channel.
CreateUnbounded
<int>();
814
Channel<string> output = Channel.
CreateUnbounded
<string>();
1030
return Channel.
CreateUnbounded
<string>().Reader;
NativeAotTests.cs (2)
249
Channel<string> output = Channel.
CreateUnbounded
<string>();
282
Channel<char> output = Channel.
CreateUnbounded
<char>();
Microsoft.CodeAnalysis.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.BannedApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.PublicApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.CodeAnalysis.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
264
var channel = Channel.
CreateUnbounded
<ServiceEndpointResolverResult>();
Roslyn.Diagnostics.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
SignalR.Client.FunctionalTestApp (3)
TestHub.cs (3)
62
var channel = Channel.
CreateUnbounded
<string>();
72
var channel = Channel.
CreateUnbounded
<string>();
100
var channel = Channel.
CreateUnbounded
<int>();
SignalRSamples (3)
Hubs\Streaming.cs (1)
32
var channel = Channel.
CreateUnbounded
<int>();
Hubs\UploadHub.cs (1)
65
var output = Channel.
CreateUnbounded
<string>();
ObservableExtensions.cs (1)
26
var channel = maxBufferSize != null ? Channel.CreateBounded<T>(maxBufferSize.Value) : Channel.
CreateUnbounded
<T>();
Stress.ApiService (2)
ProducerConsumer.cs (1)
20
private readonly Channel<Data> _channel = Channel.
CreateUnbounded
<Data>();
Program.cs (1)
167
var channel = Channel.
CreateUnbounded
<string>();
System.Net.Quic (1)
System\Net\Quic\QuicListener.cs (1)
141
_acceptQueue = Channel.
CreateUnbounded
<object>();
Test.Utilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();
TestDiscoveryWorker (1)
Program.cs (1)
116
_channel = Channel.
CreateUnbounded
<string>();
Text.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
270
var channel = Channel.
CreateUnbounded
<TItem>();