@Test public void noServiceDiscoveryEvent() { selectConnectionListener.listen(lb.selectConnection(any())); selectConnectionListener.verifyFailure(NoAvailableHostException.class); assertThat(connectionsCreated, is(empty())); }
@Override public Single<C> selectConnection(Predicate<C> selector) { return defer(() -> selectConnection0(selector).subscribeShareContext()); }
RoundRobinLoadBalancer implements LoadBalancer<C> { @Override public Single<C> selectConnection(Predicate<C> selector) { return defer(() -> selectConnection0(selector).subscribeShareContext()); } }
RoundRobinLoadBalancer implements LoadBalancer<C> { @Override public Single<C> selectConnection(Predicate<C> selector) { return defer(() -> selectConnection0(selector).subscribeShareContext()); } RoundRobinLoadBalancer(final Publisher<? extends ServiceDiscovererEvent<ResolvedAddress>> eventPublisher,
                                  final ConnectionFactory<ResolvedAddress, ? extends C> connectionFactory); }
RoundRobinLoadBalancer implements LoadBalancer<C> { @Override public Single<C> selectConnection(Predicate<C> selector) { return defer(() -> selectConnection0(selector).subscribeShareContext()); } 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(); }
RoundRobinLoadBalancer implements LoadBalancer<C> { @Override public Single<C> selectConnection(Predicate<C> selector) { return defer(() -> selectConnection0(selector).subscribeShareContext()); } 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();  }