} catch (final Exception e) {
                throw new CurlException("Failed to access the response.", e);
            }
            writeContent(() -> {
                try {
                    if (Method.HEAD.toString().equalsIgnoreCase(con.getRequestMethod())) {
                        return new ByteArrayInputStream(new byte[0]);
                    } else if (con.getResponseCode() < 400) {

        final int threadCount = 10;
        Thread[] threads = new Thread[threadCount];
        final boolean[] results = new boolean[threadCount];

        for (int i = 0; i < threadCount; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {
                String thumbnailId = "concurrent-" + index;
                File outputFile = new File(tempDir.toFile(), "concurrent-" + index + ".png");

        Map.entry("n", new NumberFieldType("n", NumberType.LONG, false, false, true, true, null, Map.of(), null, false, null))
    );
    private final IndexFieldDataCache fieldDataCache = new IndexFieldDataCache.None();
    private final CircuitBreakerService breakerService = new NoneCircuitBreakerService();
    private SearchLookup lookup = new SearchLookup(
        fieldTypes::get,

   *
   * @return this
   * @throws IllegalStateException if any of the Services are not {@link State#NEW new} when the
   *     method is called.
   */
  @CanIgnoreReturnValue
  public ServiceManager startAsync() {
    for (Service service : services) {
      checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
    }

        response = new Smb2QueryDirectoryResponse(mockConfig, expectInfoClass);

        assertNotNull(response);
        assertNull(response.getResults()); // Should be null before decoding
    }

    @Test
    @DisplayName("Test getResults returns null initially")
    void testGetResultsInitiallyNull() {
        response = new Smb2QueryDirectoryResponse(mockConfig, (byte) 0x03);

    }

    @Test
    void testResolveArtifacts() throws Exception {
        ArtifactRequest req1 = new ArtifactRequest();
        req1.setArtifact(new DefaultArtifact("ut.simple:artifact:1.0"));
        req1.addRepository(newTestRepository());

        ArtifactRequest req2 = new ArtifactRequest();
        req2.setArtifact(new DefaultArtifact("ut.simple:artifact:zip:1.0"));
        req2.addRepository(newTestRepository());

        // v1-->v2
        graph.addEdge(v1, v2, new MetadataGraphEdge("1.1", true, null, null, 2, 1));
        graph.addEdge(v1, v2, new MetadataGraphEdge("1.2", true, null, null, 2, 2));

        // v1-->v3
        graph.addEdge(v1, v3, new MetadataGraphEdge("1.1", true, null, null, 2, 1));
        graph.addEdge(v1, v3, new MetadataGraphEdge("1.2", true, null, null, 4, 2));

        // v3-->v4

        RequestParameter param = new RequestParameter(name, values);

        assertEquals("", param.getName());
        assertNotNull(param.getValues());
        assertEquals(2, param.getValues().length);
    }

    @Test
    public void test_constructor_withNullValues() {
        // Test with null values array
        String name = "paramName";
        RequestParameter param = new RequestParameter(name, null);

    CountDownLatch submitSuccessful = new CountDownLatch(1);
    ExecutorService executorService =
        new ThreadPoolExecutor(
            0,
            Integer.MAX_VALUE,
            60L,
            SECONDS,
            new SynchronousQueue<Runnable>(),
            new ThreadFactoryBuilder().setDaemon(true).build()) {
          @Override

        assertArgumentNotNull("file", file);
        assertArgumentNotEmpty("encoding", encoding);

        try {
            return new InputStreamReader(new FileInputStream(file), encoding);
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Reads a single line from the given {@link BufferedReader}.
     *
     * @param reader