### Question:
DefaultConfigurationProvider implements ConfigurationProvider { @Override public Flux<ClusterConfig> configs() { return configs; } DefaultConfigurationProvider(final Core core, final Set<SeedNode> seedNodes); @Override CollectionMap collectionMap(); @Override Flux<ClusterConfig> configs(); @Override ClusterConfig config(); @Override Flux<Set<SeedNode>> seedNodes(); @Override Mono<Void> openBucket(final String name); @Override Mono<Void> loadAndRefreshGlobalConfig(); @Override void proposeBucketConfig(final ProposedBucketConfigContext ctx); @Override void proposeGlobalConfig(final ProposedGlobalConfigContext ctx); @Override Mono<Void> closeBucket(final String name); @Override Mono<Void> shutdown(); @Override void refreshCollectionMap(final String bucket, final boolean force); @Override boolean collectionMapRefreshInProgress(); static List<AlternateAddressHolder> extractAlternateAddressInfos(final ClusterConfig config); static String determineNetworkResolution(final List<AlternateAddressHolder> nodes, final NetworkResolution nr,
                                                  final Set<String> seedHosts); @Override boolean globalConfigLoadInProgress(); @Override boolean bucketConfigLoadInProgress();  }### Answer:
@Test void currentConfigIsReplayedToLateSubscriber() { Core core = mock(Core.class); CoreContext ctx = new CoreContext(core, 1, ENVIRONMENT, mock(Authenticator.class)); when(core.context()).thenReturn(ctx); DefaultConfigurationProvider provider = new DefaultConfigurationProvider(core, SeedNode.LOCALHOST); provider.configs().blockFirst(Duration.ofSeconds(10)); }