SslClientInitializerTest.java 文件源码

private ChannelInitializer<LocalChannel> getClientInitializer(
    SslClientInitializer<LocalChannel> sslClientInitializer,
    Lock clientLock,
    ByteBuf buffer,
    Exception clientException) {
  return new ChannelInitializer<LocalChannel>() {
    @Override
    protected void initChannel(LocalChannel ch) throws Exception {
      ch.pipeline()
          .addLast(sslClientInitializer, new DumpHandler(clientLock, buffer, clientException));
    }
  };
}