newResolver() — netty Function Reference

Architecture documentation for the newResolver() function in BootstrapTest.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ newResolver() — netty Function Reference

Dependency Diagram

graph TD
  307a3e78_e035_c6f3_8243_597f5c05a3af["newResolver()"]
  d824fae0_a0a0_0d5f_3515_4ef8828bebb3["TestAddressResolverGroup"]
  307a3e78_e035_c6f3_8243_597f5c05a3af -->|defined in| d824fae0_a0a0_0d5f_3515_4ef8828bebb3
  0f23ddf0_4b99_680e_2632_bb1dc24a3193["testGetResolverFailed()"]
  0f23ddf0_4b99_680e_2632_bb1dc24a3193 -->|calls| 307a3e78_e035_c6f3_8243_597f5c05a3af
  style 307a3e78_e035_c6f3_8243_597f5c05a3af fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/bootstrap/BootstrapTest.java lines 572–612

        @Override
        protected AddressResolver<SocketAddress> newResolver(EventExecutor executor) throws Exception {
            return new AbstractAddressResolver<SocketAddress>(executor) {

                @Override
                protected boolean doIsResolved(SocketAddress address) {
                    return false;
                }

                @Override
                protected void doResolve(
                        final SocketAddress unresolvedAddress, final Promise<SocketAddress> promise) {
                    executor().execute(new Runnable() {
                        @Override
                        public void run() {
                            if (success) {
                                promise.setSuccess(unresolvedAddress);
                            } else {
                                promise.setFailure(new UnknownHostException(unresolvedAddress.toString()));
                            }
                        }
                    });
                }

                @Override
                protected void doResolveAll(
                        final SocketAddress unresolvedAddress, final Promise<List<SocketAddress>> promise)
                        throws Exception {
                    executor().execute(new Runnable() {
                        @Override
                        public void run() {
                            if (success) {
                                promise.setSuccess(Collections.singletonList(unresolvedAddress));
                            } else {
                                promise.setFailure(new UnknownHostException(unresolvedAddress.toString()));
                            }
                        }
                    });
                }
            };
        }