### Question:
PreferCurrentEventLoopHolder extends IdleConnectionsHolder<W, R> { @Override public boolean remove(PooledConnection<R, W> toRemove) { for (IdleConnectionsHolder<W, R> anElHolder : allElHolders) { if (anElHolder.remove(toRemove)) { return true; } } return false; } PreferCurrentEventLoopHolder(PreferCurrentEventLoopGroup eventLoopGroup);   PreferCurrentEventLoopHolder(PreferCurrentEventLoopGroup eventLoopGroup,
                                 final IdleConnectionsHolderFactory<W, R> holderFactory); @Override Observable<PooledConnection<R, W>> poll(); @Override Observable<PooledConnection<R, W>> pollThisEventLoopConnections(); @Override Observable<PooledConnection<R, W>> peek(); @Override void add(final PooledConnection<R, W> toAdd); @Override boolean remove(PooledConnection<R, W> toRemove);  }### Answer:
@Test(timeout = 60000) public void testRemove() throws Exception { PooledConnection<String, String> connection1 = preferCurrentELHolderRule.addConnection(); PooledConnection<String, String> connection = preferCurrentELHolderRule.holder.peek() .defaultIfEmpty(null) .toBlocking().single(); assertThat("Connection not available with peek.", connection, is(connection1)); preferCurrentELHolderRule.holder.remove(connection1); connection = preferCurrentELHolderRule.holder.peek().defaultIfEmpty(null).toBlocking().single(); assertThat("Connection not removed.", connection, is(nullValue())); }