GetRequiredKeyedService

341 references to GetRequiredKeyedService

Aspire.Azure.AI.Inference (2)

AspireAzureAIInferenceExtensions.cs (1)

212services.GetRequiredKeyedService<ChatCompletionsClient>(builder.ServiceKey);

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.AI.OpenAI (2)

AspireAzureOpenAIExtensions.cs (1)

79builder.Services.TryAddKeyedSingleton(typeof(OpenAIClient), serviceKey: name, static (provider, key) => provider.GetRequiredKeyedService<AzureOpenAIClient>(key));

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.AI.OpenAI.Tests (28)

AspireAzureAIOpenAIExtensionsTests.cs (6)

45host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 49host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 76host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 102host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 146var client2 = host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai2"); 147var client3 = host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai3");

AspireAzureOpenAIClientBuilderChatClientExtensionsTests.cs (7)

36host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 66host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 94host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 125host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 156host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 187host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 214host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") :

AspireAzureOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (7)

36host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 66host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 94host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 125host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 156host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 187host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 214host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") :

AspireConfigurableOpenAIExtensionsTests.cs (8)

Aspire.Azure.Data.Tables (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Data.Tables.Tests (6)

AspireTablesExtensionsTests.cs (6)

37host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 64host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 94host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 122host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 146var client2 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables2"); 147var client3 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables3");

Aspire.Azure.Messaging.EventHubs (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Messaging.ServiceBus (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Messaging.ServiceBus.Tests (6)

AspireServiceBusExtensionsTests.cs (6)

37host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 64host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 94host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 122host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 146var client2 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb2"); 147var client3 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb3");

Aspire.Azure.Messaging.WebPubSub (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Messaging.WebPubSub.Tests (9)

AspireWebPubSubExtensionsTests.cs (9)

Aspire.Azure.Npgsql.Tests (10)

AspireAzurePostgreSqlNpgsqlExtensionsTests.cs (10)

Aspire.Azure.Search.Documents (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Search.Documents.Tests (4)

AspireAzureSearchExtensionsTests.cs (4)

38host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 65host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 90var client2 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search2"); 91var client3 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search3");

Aspire.Azure.Security.KeyVault (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Security.KeyVault.Tests (7)

AspireKeyVaultExtensionsTests.cs (7)

42host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 72host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 195var client2 = host.Services.GetRequiredKeyedService<SecretClient>("secrets2"); 196var client3 = host.Services.GetRequiredKeyedService<SecretClient>("secrets3"); 261var secretClient = host.Services.GetRequiredKeyedService<SecretClient>(secretClientName); 262var keyClient = host.Services.GetRequiredKeyedService<KeyClient>(keyClientName); 263var certClient = host.Services.GetRequiredKeyedService<CertificateClient>(certClientName);

Aspire.Azure.Storage.Blobs (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Storage.Blobs.Tests (6)

AspireBlobStorageExtensionsTests.cs (6)

37host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 64host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 94host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 122host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 146var client2 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob2"); 147var client3 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob3");

Aspire.Azure.Storage.Queues (1)

src\Components\Common\AzureComponent.cs (1)

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

Aspire.Azure.Storage.Queues.Tests (6)

AspireQueueStorageExtensionsTests.cs (6)

37host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 64host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 94host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 122host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 146var client2 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue2"); 147var client3 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue3");

Aspire.Components.Common.TestUtilities (5)

ConformanceTests.cs (5)

241TService serviceForKey1 = host.Services.GetRequiredKeyedService<TService>(key1); 242TService serviceForKey2 = host.Services.GetRequiredKeyedService<TService>(key2); 297: host.Services.GetRequiredKeyedService<TService>(key); 390: host.Services.GetRequiredKeyedService<TService>(key)); 460: host.Services.GetRequiredKeyedService<TService>(key);

Aspire.Confluent.Kafka (12)

AspireKafkaConsumerExtensions.cs (4)

133builder.Services.AddKeyedSingleton<IConsumer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(key).Create()); 175: sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(serviceKey); 186sp => sp.GetRequiredKeyedService<KafkaHealthCheck>(healthCheckName), 197: new(serviceProvider.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(key),

AspireKafkaProducerExtensions.cs (4)

133builder.Services.AddKeyedSingleton<IProducer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(key).Create()); 175: sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(serviceKey); 186sp => sp.GetRequiredKeyedService<KafkaHealthCheck>(healthCheckName), 197: new(serviceProvider.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(key),

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Consumer.cs (1)

82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Producer.cs (1)

82producerBuilder ??= sp.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(name);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Consumer.cs (1)

82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Producer.cs (1)

82producerBuilder ??= sp.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(name);

Aspire.Confluent.Kafka.Tests (8)

ConsumerConformanceTests.cs (2)

110var client2 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging2"); 111var client3 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging3");

OtelMetricsTests.cs (2)

69? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 86? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)

OtelTracesTests.cs (2)

70? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 91? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)

ProducerConformanceTests.cs (2)

101var client2 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging2"); 102var client3 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging3");

Aspire.Hosting (3)

DistributedApplicationRunner.cs (1)

40var publisher = serviceProvider.GetRequiredKeyedService<IDistributedApplicationPublisher>(executionContext.PublisherName);

Publishing\ResourceContainerImageBuilder.cs (2)

141string rt => serviceProvider.GetRequiredKeyedService<IContainerRuntime>(rt), 142null => serviceProvider.GetRequiredKeyedService<IContainerRuntime>("docker")

Aspire.Hosting.Azure.Tests (1)

ContainerRegistryTests.cs (1)

97var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("test-publisher") as ContainerRegistryValidatingPublisher;

Aspire.Hosting.MySql.Tests (1)

MySqlFunctionalTests.cs (1)

797var conn = host.Services.GetRequiredKeyedService<MySqlConnection>(db.Resource.Name);

Aspire.Hosting.PostgreSQL.Tests (1)

PostgresFunctionalTests.cs (1)

792var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);

Aspire.Hosting.SqlServer.Tests (1)

SqlServerFunctionalTests.cs (1)

566var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);

Aspire.Hosting.Testing (1)

DistributedApplicationFactory.cs (1)

572applicationBuilder.Services.AddSingleton<IHost>(sp => new ObservedHost(sp.GetRequiredKeyedService<IHost>(this), this));

Aspire.Hosting.Tests (9)

DistributedApplicationBuilderTests.cs (1)

39Assert.NotNull(app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest"));

Helpers\JsonDocumentManifestPublisher.cs (2)

44var publisher = testProgram.App?.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest") as JsonDocumentManifestPublisher; 50var publisher = services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest") as JsonDocumentManifestPublisher;

Pipelines\DistributedApplicationPipelineTests.cs (6)

878var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default"); 918var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default"); 966var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default"); 1009var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default"); 1050var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default"); 1094var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("default");

Aspire.Microsoft.Azure.Cosmos.Tests (19)

AspireMicrosoftAzureCosmosExtensionsTests.cs (17)

ConformanceTests.cs (2)

93var client2 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb2"); 94var client3 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb3");

Aspire.Microsoft.Data.SqlClient.Tests (5)

AspireSqlServerSqlClientExtensionsTests.cs (5)

37host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 65host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 97host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 122var connection2 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection2"); 123var connection3 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection3");

Aspire.Milvus.Client (1)

AspireMilvusExtensions.cs (1)

94: sp.GetRequiredKeyedService<MilvusClient>(serviceKey)),

Aspire.Milvus.Client.Tests (5)

AspireMilvusExtensionTests.cs (3)

50host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 74host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 104host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) :

ConformanceTests.cs (2)

121var client2 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus2"); 122var client3 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus3");

Aspire.MongoDB.Driver (2)

src\Components\Aspire.MongoDB.Driver\AspireMongoDBDriverExtensions.cs (2)

153.GetRequiredKeyedService<IMongoClient>(serviceKey) 178: sp => sp.GetRequiredKeyedService<IMongoClient>(serviceKey),

Aspire.MongoDB.Driver.Tests (3)

AspireMongoDBDriverExtensionsTests.cs (3)

86var mongoClient = host.Services.GetRequiredKeyedService<IMongoClient>(key); 220var connection2 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb2"); 221var connection3 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb3");

Aspire.MongoDB.Driver.v3.Tests (3)

tests\Aspire.MongoDB.Driver.Tests\AspireMongoDBDriverExtensionsTests.cs (3)

Aspire.MySqlConnector (1)

AspireMySqlConnectorExtensions.cs (1)

86: sp.GetRequiredKeyedService<MySqlDataSource>(serviceKey))),

Aspire.MySqlConnector.Tests (5)

AspireMySqlConnectorExtensionsTests.cs (5)

45host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 73host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 105host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 130var connection2 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql2"); 131var connection3 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql3");

Aspire.NATS.Net (2)

AspireNatsClientExtensions.cs (2)

165builder.Services.TryAddKeyedSingleton<INatsConnection>(serviceKey, static (provider, key) => provider.GetRequiredKeyedService<NatsConnection>(key)); 174: sp.GetRequiredKeyedService<INatsConnection>(serviceKey)),

Aspire.NATS.Net.Tests (7)

AspireNatsClientExtensionsTests.cs (6)

53host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 80host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 111host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 143host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 253var connection2 = host.Services.GetRequiredKeyedService<INatsConnection>("nats2"); 254var connection3 = host.Services.GetRequiredKeyedService<INatsConnection>("nats3");

NatsClientPublicApiTests.cs (1)

209? host.Services.GetRequiredKeyedService<INatsConnection>(name)

Aspire.Npgsql (1)

AspirePostgreSqlNpgsqlExtensions.cs (1)

84: sp.GetRequiredKeyedService<NpgsqlDataSource>(serviceKey))),

Aspire.Npgsql.Tests (6)

AspirePostgreSqlNpgsqlExtensionsTests.cs (6)

37host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 65host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 97host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 129host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 152var connection2 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql2"); 153var connection3 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql3");

Aspire.OpenAI (2)

AspireOpenAIClientBuilderChatClientExtensions.cs (1)

65: services.GetRequiredKeyedService<OpenAIClient>(builder.ServiceKey);

AspireOpenAIClientBuilderEmbeddingGeneratorExtensions.cs (1)

65: services.GetRequiredKeyedService<OpenAIClient>(builder.ServiceKey);

Aspire.OpenAI.Tests (21)

AspireOpenAIClientBuilderChatClientExtensionsTests.cs (8)

AspireOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (8)

AspireOpenAIExtensionsTests.cs (5)

38host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 65host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 110host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 162var client2 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai2"); 163var client3 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai3");

Aspire.Qdrant.Client (1)

AspireQdrantExtensions.cs (1)

94sp.GetRequiredKeyedService<QdrantClient>(serviceKey)),

Aspire.Qdrant.Client.Tests (2)

AspireQdrantClientExtensionsTest.cs (2)

104var client2 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant2"); 105var client3 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant3");

Aspire.RabbitMQ.Client (2)

AspireRabbitMQExtensions.cs (2)

126builder.Services.AddKeyedSingleton<IConnection>(serviceKey, (sp, key) => CreateConnection(sp.GetRequiredKeyedService<IConnectionFactory>(key), settings.MaxConnectRetryCount)); 159var connection = serviceKey is null ? sp.GetRequiredService<IConnection>() : sp.GetRequiredKeyedService<IConnection>(serviceKey);

Aspire.RabbitMQ.Client.Tests (6)

AspireRabbitMQExtensionsTests.cs (6)

47host.Services.GetRequiredKeyedService<IConnection>("messaging") : 76host.Services.GetRequiredKeyedService<IConnection>("messaging") : 107host.Services.GetRequiredKeyedService<IConnection>("messaging") : 183var connection2 = host.Services.GetRequiredKeyedService<IConnection>("messaging2"); 184var connection3 = host.Services.GetRequiredKeyedService<IConnection>("messaging3"); 220.GetRequiredKeyedService<IConnection>(useKeyed ? "messaging" : null);

Aspire.RabbitMQ.Client.v7.Tests (6)

tests\Aspire.RabbitMQ.Client.Tests\AspireRabbitMQExtensionsTests.cs (6)

Aspire.StackExchange.Redis (1)

AspireRedisExtensions.cs (1)

180connectionMultiplexerFactory: sp => serviceKey is null ? sp.GetRequiredService<IConnectionMultiplexer>() : sp.GetRequiredKeyedService<IConnectionMultiplexer>(serviceKey),

Aspire.StackExchange.Redis.DistributedCaching (3)

AspireRedisDistributedCacheExtensions.cs (3)

74options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name)); 112options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(key)); 168options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(builder.ServiceKey));

Aspire.StackExchange.Redis.DistributedCaching.Tests (5)

AspireRedisDistributedCacheExtensionsTests.cs (5)

96var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 97var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 98var dcache1 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache1"); 99var dcache2 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache2"); 100var dcache3 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache3");

Aspire.StackExchange.Redis.OutputCaching (2)

AspireRedisOutputCacheExtensions.cs (2)

73options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name)); 95options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(key));

Aspire.StackExchange.Redis.Tests (11)

AspireRedisExtensionsTests.cs (11)

Microsoft.AspNetCore.OpenApi (6)

Services\OpenApiDocumentProvider.cs (1)

50var targetDocumentService = serviceProvider.GetRequiredKeyedService<OpenApiDocumentService>(lowercasedDocumentName);

Services\OpenApiDocumentService.cs (1)

42private readonly OpenApiSchemaService _componentService = serviceProvider.GetRequiredKeyedService<OpenApiSchemaService>(documentName);

Transformers\DelegateOpenApiDocumentTransformer.cs (1)

32var documentService = context.ApplicationServices.GetRequiredKeyedService<OpenApiDocumentService>(context.DocumentName);

Transformers\OpenApiDocumentTransformerContext.cs (1)

49var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);

Transformers\OpenApiOperationTransformerContext.cs (1)

48var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);

Transformers\OpenApiSchemaTransformerContext.cs (1)

72var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);

Microsoft.AspNetCore.OpenApi.Tests (5)

Extensions\OpenApiServiceCollectionExtensionsTests.cs (4)

214var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(Microsoft.AspNetCore.OpenApi.OpenApiConstants.DefaultDocumentName); 239var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant()); 261var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant()); 291var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant());

Integration\OpenApiDocumentIntegrationTests.cs (1)

101var documentService = fixture.Services.GetRequiredKeyedService<OpenApiDocumentService>(documentName);

Microsoft.Extensions.AI (1)

Embeddings\EmbeddingGeneratorBuilderServiceCollectionExtensions.cs (1)

109static (services, serviceKey) => services.GetRequiredKeyedService<IEmbeddingGenerator<TInput, TEmbedding>>(serviceKey), lifetime));

Microsoft.Extensions.AI.Tests (18)

ChatCompletion\DependencyInjectionPatterns.cs (6)

75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey");

Image\ImageGeneratorDependencyInjectionPatterns.cs (6)

75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey");

SpeechToText\SpeechToTextClientDependencyInjectionPatterns.cs (6)

75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey");

Microsoft.Extensions.Caching.Hybrid (1)

Internal\DefaultHybridCache.cs (1)

84: services.GetRequiredKeyedService<IDistributedCache>(_options.DistributedCacheServiceKey);

Microsoft.Extensions.Caching.Hybrid.Tests (49)

ServiceConstructionTests.cs (49)

Microsoft.Extensions.DependencyInjection.Abstractions (1)

ServiceProviderKeyedServiceExtensions.cs (1)

101return provider.GetRequiredKeyedService<IEnumerable<T>>(serviceKey);

Microsoft.Extensions.Http.Diagnostics (2)

Logging\HttpClientLoggingHttpClientBuilderExtensions.cs (1)

99serviceProvider => serviceProvider.GetRequiredKeyedService<HttpClientLogger>(builder.Name),

Logging\Internal\ServiceProviderExtensions.cs (1)

24: provider.GetRequiredKeyedService<T>(serviceKey);