+
+ private void enableTimerTask() {
+ doReturn(timeout).when(timer).newTimeout(any(), eq(100L), eq(TimeUnit.MILLISECONDS));
+ }
+
+ private static final class CloseDetector extends ChannelOutboundHandlerAdapter {
+ @Override
+ public void close(final ChannelHandlerContext ctx, final ChannelPromise promise) {
+ // Override needed so @Skip from superclass is not effective
+ }
+ }