@Override
      protected void initChannel(final SocketChannel ch) throws Exception {
        final CompletableFuture<PeerConnection> connectionFuture = new CompletableFuture<>();
        connectionFuture.thenAccept(
            connection -> connectSubscribers.forEach(c -> c.onConnect(connection)));
        ch.pipeline()
            .addLast(
                timeoutHandler(
                    connectionFuture, "Timed out waiting to fully establish incoming connection"));
        addAdditionalInboundHandlers(ch);
        ch.pipeline().addLast(inboundHandler(connectionFuture));
      }
@return a channel initializer for inbound connections
ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/rlpx/connections/netty/NettyConnectionInitializer.java