runClient() — netty Function Reference

Architecture documentation for the runClient() function in JdkDelegatingPrivateKeyMethodTest.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 2

Entity Profile

Buffer→ Allocators→ runClient() — netty Function Reference

Dependency Diagram

graph TD
  258ca29b_254c_5099_2a8a_08100b96b77c["runClient()"]
  2ac7122d_91ea_6ce8_76a0_fb9ed7fcbdbc["JdkDelegatingPrivateKeyMethodTest"]
  258ca29b_254c_5099_2a8a_08100b96b77c -->|defined in| 2ac7122d_91ea_6ce8_76a0_fb9ed7fcbdbc
  a7f8dd70_f64f_5b30_337b_7aeea3a1751c["testMultipleHandshakes()"]
  a7f8dd70_f64f_5b30_337b_7aeea3a1751c -->|calls| 258ca29b_254c_5099_2a8a_08100b96b77c
  a847fd95_75bd_8b53_9b1c_7d94990f5181["String()"]
  a847fd95_75bd_8b53_9b1c_7d94990f5181 -->|calls| 258ca29b_254c_5099_2a8a_08100b96b77c
  35d1a24b_27ed_ea5f_b5fe_daf98be66d95["ClientHandler()"]
  258ca29b_254c_5099_2a8a_08100b96b77c -->|calls| 35d1a24b_27ed_ea5f_b5fe_daf98be66d95
  style 258ca29b_254c_5099_2a8a_08100b96b77c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/JdkDelegatingPrivateKeyMethodTest.java lines 469–492

    private static Future<String> runClient(int serverPort, SslContext clientSslContext) {
        Promise<String> resultPromise = GROUP.next().newPromise();
        Bootstrap clientBootstrap = new Bootstrap()
                .group(GROUP)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) {
                        ChannelPipeline pipeline = ch.pipeline();
                        SslHandler sslHandler = clientSslContext.newHandler(ch.alloc(),
                                "localhost", serverPort);
                        pipeline.addLast(sslHandler);
                        pipeline.addLast(new ClientHandler(resultPromise));
                    }
                });

        clientBootstrap.connect("localhost", serverPort)
                .addListener(future -> {
                    if (!future.isSuccess()) {
                        resultPromise.tryFailure(future.cause());
                    }
                });
        return resultPromise;
    }