### Question:
PreferCurrentEventLoopHolder extends IdleConnectionsHolder<W, R> { @Override public Observable<PooledConnection<R, W>> pollThisEventLoopConnections() { return Observable.create(new OnSubscribe<PooledConnection<R, W>>() { @Override public void call(Subscriber<? super PooledConnection<R, W>> subscriber) { final IdleConnectionsHolder<W, R> holderForThisEL = perElHolder.get(); if (null == holderForThisEL) { PreferCurrentEventLoopHolder.super.pollThisEventLoopConnections().unsafeSubscribe(subscriber); } else { holderForThisEL.poll().unsafeSubscribe(subscriber); } } }); } 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 public void testPollThisEventLoopConnectionsInEl() throws Exception { final PooledConnection<String, String> connection1 = preferCurrentELHolderRule.addConnection(); preferCurrentELHolderRule.runFromChannelEventLoop(new Callable<Void>() { @Override public Void call() throws Exception { PooledConnection<String, String> connection = preferCurrentELHolderRule.holder.pollThisEventLoopConnections() .defaultIfEmpty(null) .toBlocking().single(); assertThat("Connection available in the eventloop.", connection, is(connection1)); return null; } }).get(1, TimeUnit.MINUTES); }