183 references to CreateUnbounded
Aspire.Cli.Tests (5)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
447var source = Channel.CreateUnbounded<ResourceSnapshot>();
Commands\AgentMcpCommandTests.cs (2)
357var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 445var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>();
Commands\LogsCommandTests.cs (1)
1435var logLines = Channel.CreateUnbounded<string>();
TestServices\TestAuxiliaryBackchannelMonitor.cs (1)
15private readonly Channel<bool> _connectionChanges = Channel.CreateUnbounded<bool>();
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>();
Aspire.Dashboard (1)
ServiceClient\DashboardClient.cs (1)
61private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();
Aspire.Dashboard.Components.Tests (107)
Dialogs\ManageDataDialogTests.cs (2)
42var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 253var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Interactions\InteractionsProviderTests.cs (20)
60var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 86var liveInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var liveRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 88var selectedInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 89var selectedRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 138var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 185var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 236var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 237var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 295var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 296var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 359var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 360var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 432var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 433var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 510var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 511var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 568var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 569var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 630var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>();
Pages\ConsoleLogsTerminalTests.cs (20)
43var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 44var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 95var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 96var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 145var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 146var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 196var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 197var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 242var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 243var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 302var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 303var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 350var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 351var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 392var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 393var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 454var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 455var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 533var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 534var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ConsoleLogsTests.cs (43)
41var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 42var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 43var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 91var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 92var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 93var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 152consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 180var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 181var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 283var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 284var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 335var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 336var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 382var liveConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 383var repositoryConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 384var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 427consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 428resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 445var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 446var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 486var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 487var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 512var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 513var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 561var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 562var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 610var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 611var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 675var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 676var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 713var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 714var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 768var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 769var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 809var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 810var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 885consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 886resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 920var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 921var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 922var resourceCommandChannel = Channel.CreateUnbounded<ResourceCommandResponseViewModel>(); 979var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 980var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourcesTests.cs (20)
56resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 87var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 186var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 238var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 274var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [resource], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 315var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 343var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 374var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 402resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 497var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 631var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 658var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 687var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 717var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 749var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 831var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 874var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 908var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 952var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 991resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>,
Shared\ResourceSetupHelpers.cs (1)
66context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>));
tests\Shared\TestDashboardTelemetrySender.cs (1)
12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();
Aspire.Dashboard.Tests (14)
ChannelExtensionsTests.cs (6)
58var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 82var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 106var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 107var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>(); 150var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 151var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>();
Integration\DashboardClientAuthTests.cs (1)
171public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ResourceInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();
ResourceOutgoingPeerResolverTests.cs (5)
285var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 286var resultChannel = Channel.CreateUnbounded<(int ChangeCount, long Timestamp)>(); 364var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 383var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 400var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
TelemetryRepositoryTests\LogTests.cs (1)
966var resultChannel = Channel.CreateUnbounded<int>();
tests\Shared\TestDashboardTelemetrySender.cs (1)
12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();
Aspire.Hosting (7)
ApplicationModel\ResourceLoggerService.cs (3)
228var channel = Channel.CreateUnbounded<LogSubscriber>(); 317var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 460var channel = Channel.CreateUnbounded<LogEntry>();
ApplicationModel\ResourceNotificationService.cs (1)
763var channel = Channel.CreateUnbounded<ResourceEvent>();
Backchannel\BackchannelLoggerProvider.cs (1)
25var channel = Channel.CreateUnbounded<BackchannelLogEntry>();
InteractionService.cs (1)
648var channel = Channel.CreateUnbounded<Interaction>();
Pipelines\PipelineActivityReporter.cs (1)
523internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Azure.Tests (1)
tests\Shared\TestInteractionService.cs (1)
23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Browsers.Tests (1)
tests\Shared\TestInteractionService.cs (1)
23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.DevTunnels.Tests (1)
tests\Shared\TestInteractionService.cs (1)
23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
356var progressChannel = Channel.CreateUnbounded<float>();
Aspire.Hosting.RemoteHost.Tests (1)
tests\Shared\TestInteractionService.cs (1)
23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Tests (26)
Cli\CliOrphanDetectorTests.cs (2)
146var processRunningChannel = Channel.CreateUnbounded<int>(); 216var processRunningChannel = Channel.CreateUnbounded<int>();
Dashboard\DashboardEventHandlersTests.cs (2)
41var logChannel = Channel.CreateUnbounded<WriteContext>(); 94var logChannel = Channel.CreateUnbounded<WriteContext>();
Dashboard\DashboardServiceTests.cs (1)
40var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();
Dcp\DcpExecutorTests.cs (8)
139var channel = Channel.CreateUnbounded<string>(); 1491var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 2082var followStdErrPipeChannel = Channel.CreateUnbounded<Pipe>(); 3750var allocatedPortChannel = Channel.CreateUnbounded<int>(); 3751var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 3826var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 3903var resolvedUrlChannel = Channel.CreateUnbounded<string?>(); 3950var resolvedUrlChannel = Channel.CreateUnbounded<string?>();
Dcp\TestKubernetesService.cs (1)
283var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();
DistributedApplicationTests.cs (1)
1209var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>();
Health\ResourceHealthCheckServiceTests.cs (2)
148var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 293var channel = Channel.CreateUnbounded<DateTimeOffset>();
InteractionServiceTests.cs (3)
126var updates = Channel.CreateUnbounded<Interaction>(); 899var updates = Channel.CreateUnbounded<Interaction>(); 952var updates = Channel.CreateUnbounded<Interaction>();
ResourceCommandServiceTests.cs (2)
136var commandResourcesChannel = Channel.CreateUnbounded<string>(); 173var commandResourcesChannel = Channel.CreateUnbounded<string>();
ResourceLoggerServiceTests.cs (3)
263var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 267var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 482var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();
tests\Shared\TestInteractionService.cs (1)
23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
18_channel = Channel.CreateUnbounded<T>();
Utils\Grpc\TestServerStreamWriter.cs (1)
18_channel = Channel.CreateUnbounded<T>();
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
277var outputChannel = Channel.CreateUnbounded<TResult>();
Internal\InvocationRequest.cs (1)
88private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();
Microsoft.CodeAnalysis.Analyzers (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
266var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();
Roslyn.Diagnostics.Analyzers (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Stress.ApiService (2)
ProducerConsumer.cs (1)
20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();
Program.cs (1)
282var channel = Channel.CreateUnbounded<string>();
System.Net.Quic (1)
System\Net\Quic\QuicListener.cs (1)
143_acceptQueue = Channel.CreateUnbounded<object>();