@Test
    public void test_startProcess_withBufferSizeAndCallback() {
        String sessionId = "test_session_buffer";
        List<String> cmdList = Arrays.asList("echo", "hello world");
        Consumer<ProcessBuilder> pbCall = pb -> {
            pb.redirectErrorStream(true);
        };

        List<String> outputs = new ArrayList<>();
        Consumer<String> outputCallback = output -> outputs.add(output);

        try {

         * @param p The process to monitor.
         * @param ist The input stream thread.
         * @param timeout The destruction timeout.
         */
        public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) {
            this.p = p;
            this.ist = ist;
            this.timeout = timeout;
        }

        /**

                    "Blowfish cipher is deprecated due to its 64-bit block size vulnerability. Please consider migrating to AES. algorithm={}",
                    cipherAlgorithm);
            inver = InvertibleCryptographer.createBlowfishCipher(fessConfig.getAppCipherKey());
        } else if ("des".equalsIgnoreCase(cipherAlgorithm)) {

                            final List<?> list = mapper.readValue(jsonBytes, List.class);

                            final List<RequestParameter> result = new ArrayList<>();
                            for (Object item : list) {
                                if (item instanceof List<?> pair) {
                                    if (pair.size() == 2 && pair.get(0) instanceof String name

        return doBatchInsert(new BulkList<>(list, call, entityCall), null);
    }

    public int[] batchUpdate(List<AccessToken> list) {
        return batchUpdate(list, null, null);
    }

    public int[] batchUpdate(List<AccessToken> list, RequestOptionCall<BulkRequestBuilder> call) {
        return batchUpdate(list, call, null);
    }

    public int[] batchUpdate(List<AccessToken> list, RequestOptionCall<BulkRequestBuilder> call,

    }

    public int[] batchInsert(List<ElevateWordToLabel> list) {
        return batchInsert(list, null, null);
    }

    public int[] batchInsert(List<ElevateWordToLabel> list, RequestOptionCall<BulkRequestBuilder> call) {
        return batchInsert(list, call, null);
    }

    public int[] batchInsert(List<ElevateWordToLabel> list, RequestOptionCall<BulkRequestBuilder> call,

    }

    public int[] batchUpdate(List<RelatedContent> list) {
        return batchUpdate(list, null, null);
    }

    public int[] batchUpdate(List<RelatedContent> list, RequestOptionCall<BulkRequestBuilder> call) {
        return batchUpdate(list, call, null);
    }

        return doBatchInsert(new BulkList<>(list, call, entityCall), null);
    }

    public int[] batchUpdate(List<RelatedQuery> list) {
        return batchUpdate(list, null, null);
    }

    public int[] batchUpdate(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call) {
        return batchUpdate(list, call, null);
    }

    public int[] batchUpdate(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call,

                listOf(listOf(performanceTestDuration))
            }
            val smallElementAggregateFunction: (List<PerformanceTestDuration>) -> List<PerformanceTestDuration> = { it }

            val buckets: List<List<PerformanceTestDuration>> =
                splitIntoBuckets(
                    list,
                    toIntFunction,
                    largeElementSplitFunction,

        return doBatchInsert(new BulkList<>(list, call, entityCall), null);
    }

    public int[] batchUpdate(List<ScheduledJob> list) {
        return batchUpdate(list, null, null);
    }

    public int[] batchUpdate(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call) {
        return batchUpdate(list, call, null);
    }

    public int[] batchUpdate(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call,