// With threshold 1, writing 1 byte should stay in memory
        ContentOutputStream cos = new ContentOutputStream(1, Curl.tmpDir);
        cos.write(new byte[] { 1 });
        assertTrue(cos.isInMemory());
        assertFalse(cos.done);
        cos.close();
    }

    @Test
    public void testThresholdOneExceeded() throws IOException {
        // With threshold 1, writing 2 bytes should go to file

        this.encoding = encoding;
        return this;
    }

    /**
     * Sets the threshold size for the request body.
     *
     * @param threshold the threshold
     * @return this CurlRequest instance
     */
    public CurlRequest threshold(final int threshold) {
        this.threshold = threshold;
        return this;
    }

    /**
     * Enables GZIP compression for the request.
     *

    /**
     * Constructs a ContentOutputStream with a specified threshold and temporary directory.
     *
     * @param threshold the threshold in bytes for writing to memory before writing to a file
     * @param tmpDir the temporary directory to create the file in
     */
    public ContentOutputStream(final int threshold, final File tmpDir) {
        super(threshold, PREFIX, SUFFIX, tmpDir);
    }

    @Override

    public void testThresholdMethod() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");
        int threshold = 2048;

        CurlRequest result = request.threshold(threshold);

        assertSame(request, result); // Fluent API
        assertEquals(threshold, request.threshold());
    }

    @Test
    public void testGzipMethod() {

        }
    }

    @Override
    public Object clone() {
        final ArrayMap<K, V> copy = new ArrayMap<>();
        copy.threshold = threshold;
        copy.mapTable = Arrays.copyOf(mapTable, size);
        copy.listTable = Arrays.copyOf(listTable, size);
        copy.size = size;
        return copy;
    }

    /**
     * Returns the index of the entry.
     *
     * @param entry

    }

    /**
     * Deletes old words based on a threshold date.
     * @param threshold The threshold date.
     * @return The SuggestDeleteResponse.
     */
    public SuggestDeleteResponse deleteOldWords(final ZonedDateTime threshold) {
        if (logger.isInfoEnabled()) {
            logger.info("Deleting old words: index={}, threshold={}", index, threshold);
        }
        final long start = System.currentTimeMillis();

     * Specified failure types will not be logged or counted as errors.
     */
    @Size(max = 1000)
    public String ignoreFailureType;

    /**
     * Threshold for failure count before stopping crawling of a URL.
     * Set to -1 to disable the threshold check.
     */
    @Required
    @Min(-1)
    @Max(10000)
    @ValidateTypeFailure
    public Integer failureCountThreshold;

    /**

        // Minimal sleep to ensure timestamp separation (reduced from 2000ms to 100ms total)
        Thread.sleep(50);
        ZonedDateTime threshold = ZonedDateTime.now();
        Thread.sleep(50);

        // Index new data after threshold
        document = new HashMap<>();
        document.put(field, "検索エンジン");
        suggester.indexer().indexFromDocument(new Map[] { document });

                            responseData.setResponseBody(file, false);
                            if (logger.isDebugEnabled()) {
                                logger.debug("File size exceeds cache threshold, using file reference: file={}, size={}, threshold={}",
                                        file.getAbsolutePath(), file.length(), maxCachedContentSize);
                            }
                        }
                    }

        // ## Assert ##
        assertEquals(getViaFactory.method(), getViaConstructor.method());
        assertEquals(getViaFactory.encoding(), getViaConstructor.encoding());
        assertEquals(getViaFactory.threshold(), getViaConstructor.threshold());
    }

    /*
    @Test
    public void test_Get_ssl() throws Exception {
        final String filename = "config/certs/http_ca.crt";