@Test(expected = IllegalArgumentException.class) public void testRejectSingletonConnectionProvider() { Connection con = Mockito.mock(Connection.class); NonBlockingConnectionPool.builder().connectionProvider(ConnectionProvider.from(con)); }
public static Builder<NonBlockingConnectionPool> builder() { return new Builder<NonBlockingConnectionPool>(x -> x); }
NonBlockingConnectionPool implements Pool<Connection> { public static Builder<NonBlockingConnectionPool> builder() { return new Builder<NonBlockingConnectionPool>(x -> x); } }
NonBlockingConnectionPool implements Pool<Connection> { public static Builder<NonBlockingConnectionPool> builder() { return new Builder<NonBlockingConnectionPool>(x -> x); } NonBlockingConnectionPool(org.davidmoten.rx.pool.NonBlockingPool.Builder<Connection> builder); }
NonBlockingConnectionPool implements Pool<Connection> { public static Builder<NonBlockingConnectionPool> builder() { return new Builder<NonBlockingConnectionPool>(x -> x); } NonBlockingConnectionPool(org.davidmoten.rx.pool.NonBlockingPool.Builder<Connection> builder); static Builder<NonBlockingConnectionPool> builder(); @Override Single<Member<Connection>> member(); @Override void close(); }
NonBlockingConnectionPool implements Pool<Connection> { public static Builder<NonBlockingConnectionPool> builder() { return new Builder<NonBlockingConnectionPool>(x -> x); } NonBlockingConnectionPool(org.davidmoten.rx.pool.NonBlockingPool.Builder<Connection> builder); static Builder<NonBlockingConnectionPool> builder(); @Override Single<Member<Connection>> member(); @Override void close();  }