code: @VisibleForTesting
    protected ExecutorService createExecutor() {
      return Executors.newSingleThreadExecutor(
          new ThreadFactoryBuilder()
            .setDaemon(true)
            .setNameFormat("Logger channel to " + addr)
            .setUncaughtExceptionHandler(
                UncaughtExceptionHandlers.systemExit())
            .build());
    }
docs: Separated out for easy overriding in tests.