ClientTransport extends Transport<T, CONF> { protected Connection connectNow() { return connectNow(Duration.ofSeconds(45)); }  T doOnConnect(Consumer<? super CONF> doOnConnect); T doOnConnected(Consumer<? super Connection> doOnConnected); T doOnDisconnected(Consumer<? super Connection> doOnDisconnected); T host(String host); T noProxy(); T port(int port); T proxy(Consumer<? super ProxyProvider.TypeSpec> proxyOptions); T remoteAddress(Supplier<? extends SocketAddress> remoteAddressSupplier); T resolver(AddressResolverGroup<?> resolver); T resolver(Consumer<NameResolverProvider.NameResolverSpec> nameResolverSpec); @Override T runOn(LoopResources loopResources, boolean preferNative);  }
@Test(expected = NullPointerException.class) public void testConnectMonoEmpty() { new TestClientTransport(Mono.empty()).connectNow(Duration.ofMillis(Long.MAX_VALUE)); }
@Test(expected = IllegalStateException.class) public void testConnectTimeout() { new TestClientTransport(Mono.never()).connectNow(Duration.ofMillis(1)); }
@Test(expected = ArithmeticException.class) public void testConnectTimeoutLongOverflow() { new TestClientTransport(Mono.never()).connectNow(Duration.ofMillis(Long.MAX_VALUE)); }
@Test(expected = IllegalStateException.class) public void testDisposeTimeout() { new TestClientTransport(Mono.just(EmbeddedChannel::new)).connectNow().disposeNow(Duration.ofMillis(1)); }
@Test(expected = ArithmeticException.class) public void testDisposeTimeoutLongOverflow() { new TestClientTransport(Mono.just(EmbeddedChannel::new)).connectNow().disposeNow(Duration.ofMillis(Long.MAX_VALUE)); }