diff --git a/src/main/java/dev/openfeature/sdk/multiprovider/MultiProvider.java b/src/main/java/dev/openfeature/sdk/multiprovider/MultiProvider.java index ff937241..d23015e1 100644 --- a/src/main/java/dev/openfeature/sdk/multiprovider/MultiProvider.java +++ b/src/main/java/dev/openfeature/sdk/multiprovider/MultiProvider.java @@ -95,6 +95,7 @@ public class MultiProvider extends EventProvider { List> results = initPool.invokeAll(tasks); for (Future result : results) { if (!result.get()) { + initPool.shutdown(); throw new GeneralError("init failed"); } } diff --git a/src/test/java/dev/openfeature/sdk/multiProvider/MultiProviderTest.java b/src/test/java/dev/openfeature/sdk/multiProvider/MultiProviderTest.java index 62472112..d9c8998c 100644 --- a/src/test/java/dev/openfeature/sdk/multiProvider/MultiProviderTest.java +++ b/src/test/java/dev/openfeature/sdk/multiProvider/MultiProviderTest.java @@ -41,7 +41,6 @@ class MultiProviderTest extends BaseStrategyTest { MultiProvider multiProvider = new MultiProvider(providers, strategy); multiProvider.initialize(null); - assertNotNull(multiProvider); MultiProviderMetadata metadata = (MultiProviderMetadata) multiProvider.getMetadata(); Map map = metadata.getOriginalMetadata(); assertEquals(mockMetaData1, map.get(mockProvider1.getMetadata().getName()));