### Question:
RoundRobinLoadBalancer implements LoadBalancer<C> { @Override public Completable closeAsync() { return asyncCloseable.closeAsync(); } RoundRobinLoadBalancer(final Publisher<? extends ServiceDiscovererEvent<ResolvedAddress>> eventPublisher,
                                  final ConnectionFactory<ResolvedAddress, ? extends C> connectionFactory); static RoundRobinLoadBalancerFactory<ResolvedAddress, C> newRoundRobinFactory(); @Override Single<C> selectConnection(Predicate<C> selector); @Override Publisher<Object> eventStream(); @Override Completable onClose(); @Override Completable closeAsync(); @Override Completable closeAsyncGracefully();  }### Answer:
@Test public void closeClosesConnectionFactory() throws Exception { awaitIndefinitely(lb.closeAsync()); assertTrue("ConnectionFactory not closed.", connectionFactory.isClosed()); }