code: @Override
    protected void initChannel(final Channel ch) throws Exception {
      ChannelPipeline pipeline = ch.pipeline();
  
      if (environment.sslEnabled()) {
        pipeline.addLast(new SslHandler(sslEngineFactory.get()));
      }
      if (LOGGER.isTraceEnabled()) {
        pipeline.addLast(new LoggingHandler(LogLevel.TRACE));
      }
      CredentialsProvider credentialsProvider = environment.credentialsProvider();
      Credentials credentials = credentialsProvider.get(address);
      pipeline
          .addLast(new HttpClientCodec())
          .addLast(new StartStreamHandler(bucket, credentials.getUsername(), credentials.getPassword()))
          .addLast(new ConfigHandler(configStream, currentBucketConfigRev, environment));
    }
docs: Init the pipeline with the HTTP codec and our handler which does all the json chunk
  decoding and parsing.
  <p>
  If trace logging is enabled also add the logging handler so we can figure out whats
  going on when debugging.