new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.DOCUMENT);
        SuggestItem item3 = new SuggestItem(new String[] { "テスト" }, readings, new String[] { "content" }, 3, 0, -1, new String[] { "tag1" },
                new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.DOCUMENT);

        SuggestItem[] items = new SuggestItem[3];

        for (int i = 0; i < 3; i++) {
            String[][] readings = new String[1][];
            readings[0] = new String[] { "test" + i };
            items[i] = new SuggestItem(new String[] { "テスト" + i }, readings, new String[] { "content" }, 1, 0, -1, new String[] { "tag1" },

        String[][] readings = new String[1][];
        readings[0] = new String[] { "word1" };
        items.add(new SuggestItem(new String[] { "word1" }, readings, new String[] { "content" }, 0, 10, -1, new String[] { "tag1" },
                new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.QUERY));

        // Multiple write calls should accumulate
        ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir);
        cos.write(new byte[] { 0, 1, 2 });
        assertTrue(cos.isInMemory());
        cos.write(new byte[] { 3, 4 });
        assertTrue(cos.isInMemory());
        cos.write(new byte[] { 5 });
        assertTrue(cos.isInMemory());
        assertFalse(cos.done);
        cos.close();

        Queue<UrlQueueImpl<Long>> existingQueue = new LinkedList<>();
        Map<String, AccessResultImpl<Long>> accessResultMap = new HashMap<>();

        UrlQueueImpl<Long> newUrl1 = new UrlQueueImpl<>();
        newUrl1.setSessionId(sessionId);
        newUrl1.setUrl("https://example.com/new1");

        UrlQueueImpl<Long> newUrl2 = new UrlQueueImpl<>();
        newUrl2.setSessionId(sessionId);

        SmbClient client = new SmbClient();
        client.setResolveSids(false);
        StandardCrawlerContainer container =
                new StandardCrawlerContainer().singleton("smbClient", client).singleton("mimeTypeHelper", MimeTypeHelperImpl.class);

        Map<String, Object> params = new HashMap<>();
        SmbAuthentication auth = new SmbAuthentication();
        auth.setUsername("testuser");

        // Test getCrawlDelay when no directive matches
        RobotsTxt robotsTxt = new RobotsTxt();

        assertEquals(0, robotsTxt.getCrawlDelay("MyBot"));
    }

    public void test_getCrawlDelayWithDirective() {
        // Test getCrawlDelay with directive
        RobotsTxt robotsTxt = new RobotsTxt();

        Directive directive = new Directive("MyBot");
        directive.setCrawlDelay(5);

        String[] words = new String[] { "検索", "エンジン" };
        String[][] readings = new String[][] { new String[] { "kensaku" }, new String[] { "enjin" } };
        String[] fields = new String[] { "content" };
        String[] tags = new String[] { "tag1" };
        String[] roles = new String[] { "role1" };
        String[] langs = new String[] { "ja" };

        NullResponseProcessor processor = new NullResponseProcessor();
        ResponseData responseData1 = new ResponseData();
        responseData1.setUrl("https://example.com/page1");

        ResponseData responseData2 = new ResponseData();
        responseData2.setUrl("https://example.com/page2");

        ResponseData responseData3 = new ResponseData();
        responseData3.setUrl("https://example.com/page3");

        CurlRequest request = new CurlRequest(Method.GET, url);

        // Add additional param
        request.param("new", "value");

        assertNotNull(request);
    }

    @Test
    public void testMultipleThreadPoolCalls() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");
        ForkJoinPool pool1 = new ForkJoinPool(2);