@Test(timeout = 60000) public void testAdd() throws Exception { PooledConnection<String, String> added = holderRule.addAConnection(); holderRule.peekNow(added); PooledConnection<String, String> added2 = holderRule.addAConnection(); holderRule.peekNow(added, added2); }
@Override public void add(PooledConnection<R, W> toAdd) { idleConnections.add(toAdd); }
FIFOIdleConnectionsHolder extends IdleConnectionsHolder<W, R> { @Override public void add(PooledConnection<R, W> toAdd) { idleConnections.add(toAdd); } }
FIFOIdleConnectionsHolder extends IdleConnectionsHolder<W, R> { @Override public void add(PooledConnection<R, W> toAdd) { idleConnections.add(toAdd); } FIFOIdleConnectionsHolder(); }
FIFOIdleConnectionsHolder extends IdleConnectionsHolder<W, R> { @Override public void add(PooledConnection<R, W> toAdd) { idleConnections.add(toAdd); } FIFOIdleConnectionsHolder(); @Override Observable<PooledConnection<R, W>> poll(); @Override Observable<PooledConnection<R, W>> peek(); @Override void add(PooledConnection<R, W> toAdd); @Override boolean remove(PooledConnection<R, W> toRemove); }
FIFOIdleConnectionsHolder extends IdleConnectionsHolder<W, R> { @Override public void add(PooledConnection<R, W> toAdd) { idleConnections.add(toAdd); } FIFOIdleConnectionsHolder(); @Override Observable<PooledConnection<R, W>> poll(); @Override Observable<PooledConnection<R, W>> peek(); @Override void add(PooledConnection<R, W> toAdd); @Override boolean remove(PooledConnection<R, W> toRemove);  }