CreateUnbounded

Commands\AgentMcpCommandTests.cs (2)

380var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 475var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>();

ActivityNotifier.cs (1)

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

ServiceClient\DashboardClient.cs (1)

51private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();

Interactions\InteractionsProviderTests.cs (13)

60var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 134var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 185var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 186var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 244var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 245var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 307var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 308var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 380var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 381var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 458var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 459var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();

Pages\ConsoleLogsTests.cs (28)

Pages\ResourcesTests.cs (14)

Shared\ResourceSetupHelpers.cs (1)

63context.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>();

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)

156public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ResourceInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();

Mcp\AspireResourceMcpToolsTests.cs (1)

133var logsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();

Model\AIAssistant\AIContextProviderTests.cs (1)

81var changeChannel = Channel.CreateUnbounded<AIContext?>();

Model\AIAssistant\AssistantChatDataContextTests.cs (1)

98var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();

ResourceOutgoingPeerResolverTests.cs (2)

131var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 132var 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)

225var channel = Channel.CreateUnbounded<LogSubscriber>(); 314var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 436var channel = Channel.CreateUnbounded<LogEntry>();

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\BackchannelLoggerProvider.cs (1)

23var channel = Channel.CreateUnbounded<BackchannelLogEntry>();

InteractionService.cs (1)

452var channel = Channel.CreateUnbounded<Interaction>();

Pipelines\PipelineActivityReporter.cs (1)

486internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();

tests\Shared\TestInteractionService.cs (1)

14public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

Cli\CliOrphanDetectorTests.cs (2)

116var processRunningChannel = Channel.CreateUnbounded<int>(); 186var processRunningChannel = Channel.CreateUnbounded<int>();

Dashboard\DashboardLifecycleHookTests.cs (1)

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

Dashboard\DashboardServiceTests.cs (1)

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

Dcp\DcpExecutorTests.cs (2)

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

Dcp\TestKubernetesService.cs (1)

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

DistributedApplicationTests.cs (1)

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

Health\ResourceHealthCheckServiceTests.cs (2)

148var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 293var channel = Channel.CreateUnbounded<DateTimeOffset>();

InteractionServiceTests.cs (3)

125var updates = Channel.CreateUnbounded<Interaction>(); 816var updates = Channel.CreateUnbounded<Interaction>(); 869var updates = Channel.CreateUnbounded<Interaction>();

ResourceCommandServiceTests.cs (2)

80var commandResourcesChannel = Channel.CreateUnbounded<string>(); 117var commandResourcesChannel = Channel.CreateUnbounded<string>();

ResourceLoggerServiceTests.cs (2)

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

tests\Shared\TestInteractionService.cs (1)

14public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

Utils\Grpc\TestAsyncStreamReader.cs (1)

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

Utils\Grpc\TestServerStreamWriter.cs (1)

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

UI\SpectreBuildParametersSelectionPrompt.cs (1)

115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();