connect() — netty Function Reference

Architecture documentation for the connect() function in ResolveAddressHandler.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ connect() — netty Function Reference

Dependency Diagram

graph TD
  1ce462a0_7cbf_88ed_d80e_f194cfe4f38f["connect()"]
  85b1544b_87af_d04d_e4c6_6e94b6749f73["ResolveAddressHandler"]
  1ce462a0_7cbf_88ed_d80e_f194cfe4f38f -->|defined in| 85b1544b_87af_d04d_e4c6_6e94b6749f73
  style 1ce462a0_7cbf_88ed_d80e_f194cfe4f38f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/address/ResolveAddressHandler.java lines 44–62

    @Override
    public void connect(final ChannelHandlerContext ctx, SocketAddress remoteAddress,
                        final SocketAddress localAddress, final ChannelPromise promise)  {
        AddressResolver<? extends SocketAddress> resolver = resolverGroup.getResolver(ctx.executor());
        if (resolver.isSupported(remoteAddress) && !resolver.isResolved(remoteAddress)) {
            resolver.resolve(remoteAddress).addListener((FutureListener<SocketAddress>) future -> {
                Throwable cause = future.cause();
                if (cause != null) {
                    promise.setFailure(cause);
                } else {
                    ctx.connect(future.getNow(), localAddress, promise);
                }
                ctx.pipeline().remove(ResolveAddressHandler.this);
            });
        } else {
            ctx.connect(remoteAddress, localAddress, promise);
            ctx.pipeline().remove(this);
        }
    }