*
     * @param <T> the type of the parsed content.
     * @param parser the function to parse the content.
     * @return the parsed content.
     */
    public <T> T getContent(final Function<CurlResponse, T> parser) {
        return parser.apply(this);
    }

    /**
     * Gets the content of the response as a string.
     *
     * @return the content as a string.

    private RelatedContent createRelatedContent(String term, String content, String virtualHost) {
        RelatedContent entity = new RelatedContent();
        entity.setTerm(term);
        entity.setContent(content);
        entity.setVirtualHost(virtualHost);
        return entity;
    }

    // Mock classes

    static class MockRelatedContentBhv extends RelatedContentBhv {

        }

        @Test
        @DisplayName("getName() should return expected byte array")
        void testGetNameMethod() {
            byte[] expectedName = "TEST_CONTEXT".getBytes(StandardCharsets.UTF_8);
            CreateContextResponse response = mock(CreateContextResponse.class);
            when(response.getName()).thenReturn(expectedName);

 *         .mimeType("application/pdf")
 *         .filename("example.pdf")
 *         .maxContentLength(1024 * 1024)
 *         .extract();
 *
 *     String content = extractData.getContent();
 *     // Process the extracted content
 * } catch (IOException e) {
 *     // Handle exception
 * }
 * }
 * </pre>
 */
public class ExtractorBuilder {

    /** Logger instance for this class */

                logger.error("Failed to access {}, code: {}.", url, response.getStatusLine().getStatusCode());
                return null;
            }

            data.setContent(EntityUtils.toString(response.getEntity(), Charsets.UTF_8));
            final Header[] headers = response.getAllHeaders();
            for (final Header header : headers) {

  }

  @J2ktIncompatible
  @GwtIncompatible // SerializableTester
  public void testForPredicateSerializable() {
    checkCanReserialize(Functions.forPredicate(Predicates.equalTo(5)));
  }

  public void testConstant() {
    Function<@Nullable Object, Object> f = Functions.<Object>constant("correct");
    assertEquals("correct", f.apply(new Object()));
    assertEquals("correct", f.apply(null));

                .header("Accept", "application/json")
                .execute()) {
            final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser());
            if (logger.isDebugEnabled()) {
                logger.debug("response: {}", contentMap);
            }
            if (contentMap.containsKey("value")) {

            try (final FileInputStream in = new FileInputStream(outputFile)) {
                final ExtractData extractData = extractor.getText(in, params);
                return extractData.getContent();
            } catch (final IOException e) {
                throw new ExtractException("Could not open " + outputFile.getAbsolutePath(), e);
            }
        }
        try {

                    final Map<String, String> map = new HashMap<>();
                    map.put(ExtractData.RESOURCE_NAME_KEY, filename);
                    final String content = extractor.getText(is, map).getContent();
                    writer.write(content);
                    writer.write('\n');
                } catch (final Exception e) {
                    if (logger.isDebugEnabled()) {

    }

    /**
     * Test that connect() calls connect() on the underlying connection.
     * @throws IOException
     */
    @Test
    void testConnect() throws Exception {
        // Act
        ntlmConnection.connect();

        // Assert
        verify(mockConnection).connect();
        // Connection should be established after connect
    }