### Question:
Bootstrap extends AbstractBootstrap<Bootstrap, Channel> { public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); } Bootstrap(); private  Bootstrap(Bootstrap bootstrap); @SuppressWarnings("unchecked") Bootstrap resolver(AddressResolverGroup<?> resolver); Bootstrap remoteAddress(SocketAddress remoteAddress); Bootstrap remoteAddress(String inetHost, int inetPort); Bootstrap remoteAddress(InetAddress inetHost, int inetPort); ChannelFuture connect(); ChannelFuture connect(String inetHost, int inetPort); ChannelFuture connect(InetAddress inetHost, int inetPort); ChannelFuture connect(SocketAddress remoteAddress); ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress); @Override Bootstrap validate(); @Override @SuppressWarnings("CloneDoesntCallSuperClone") Bootstrap clone(); Bootstrap clone(EventLoopGroup group); @Override final BootstrapConfig config();  }### Answer:
@Test public void testChannelFactoryFailureNotifiesPromise() throws Exception { final RuntimeException exception = new RuntimeException("newChannel crash"); final Bootstrap bootstrap = new Bootstrap() .handler(dummyHandler) .group(groupA) .channelFactory(new ChannelFactory<Channel>() { @Override public Channel newChannel() { throw exception; } }); ChannelFuture connectFuture = bootstrap.connect(LocalAddress.ANY); assertThat(connectFuture.await(10000), is(true)); assertThat(connectFuture.cause(), sameInstance((Throwable) exception)); assertThat(connectFuture.channel(), is(not(nullValue()))); }
@Test(timeout = 10000) public void testConnectDeadLock() throws Exception { final Bootstrap bootstrapA = new Bootstrap(); bootstrapA.group(groupA); bootstrapA.channel(LocalChannel.class); bootstrapA.handler(dummyHandler); final Bootstrap bootstrapB = new Bootstrap(); bootstrapB.group(groupB); bootstrapB.channel(LocalChannel.class); bootstrapB.handler(dummyHandler); List<Future<?>> bindFutures = new ArrayList<Future<?>>(); for (int i = 0; i < 1024; i ++) { bindFutures.add(groupA.next().submit(new Runnable() { @Override public void run() { bootstrapB.connect(LocalAddress.ANY); } })); bindFutures.add(groupB.next().submit(new Runnable() { @Override public void run() { bootstrapA.connect(LocalAddress.ANY); } })); } for (Future<?> f: bindFutures) { f.sync(); } }
@Test(expected = ConnectException.class, timeout = 10000) public void testLateRegistrationConnect() throws Exception { EventLoopGroup group = new DelayedEventLoopGroup(); try { final Bootstrap bootstrapA = new Bootstrap(); bootstrapA.group(group); bootstrapA.channel(LocalChannel.class); bootstrapA.handler(dummyHandler); bootstrapA.connect(LocalAddress.ANY).syncUninterruptibly(); } finally { group.shutdownGracefully(); } }