return new ExtractData(getTextInternal(in, mimeTypeHelper, extractorFactory));
    }

    /**
     * Returns a text from the input stream.
     *
     * @param in The input stream.
     * @param mimeTypeHelper The mime type helper.
     * @param extractorFactory The extractor factory.
     * @return A text.
     */

    }

    @Test
    void readTrailerWireFormatShouldReadSixBytesSuccessfully() throws IOException {
        // Test successful reading of 6 bytes from the input stream.
        // The content of these bytes is not critical for this test, only that 6 bytes are read.
        byte[] data = { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06 }; // Sample 6 bytes

 * under the License.
 */
package org.apache.maven.plugin.internal;

import javax.inject.Inject;
import javax.inject.Named;
import javax.inject.Singleton;

import java.util.Set;
import java.util.stream.Collectors;

import org.apache.maven.api.DependencyScope;
import org.apache.maven.plugin.PluginValidationManager;
import org.eclipse.aether.RepositorySystemSession;
import org.eclipse.aether.artifact.Artifact;

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.plugin;

import java.util.List;
import java.util.stream.Collectors;

import org.apache.maven.model.Plugin;

/**
 * Exception occurring trying to resolve a plugin.
 *
 */
public class PluginResolutionException extends Exception {

      client
        .newBuilder()
        .fastFallback(false)
        .apply {
          retryOnConnectionFailure = false
        }.build()

    executeSynchronously(request)
      .assertFailureMatches("stream was reset: REFUSED_STREAM")

    assertThat(client.routeDatabase.failedRoutes).isEmpty()
    assertThat(server1.requestCount).isEqualTo(1)
    assertThat(server2.requestCount).isEqualTo(0)

     * Gets the child URL extraction rules as a stream of tag-attribute pairs.
     *
     * @param responseData the response data
     * @param resultData the result data
     * @return a stream of tag-attribute pairs
     */
    protected Stream<Pair<String, String>> getChildUrlRules(final ResponseData responseData, final ResultData resultData) {
        return childUrlRuleMap.entrySet().stream().map(e -> new Pair<>(e.getKey(), e.getValue()));

     * file output stream.
     *
     * @throws IOException if a network error occurs
     */

    @Override
    public void write(final byte[] b) throws IOException {
        write(b, 0, b.length);
    }

    /**
     * Tests whether the output stream is currently open.
     *
     * @return true if the stream is open, false otherwise
     */

                handler.processClass(packageName, shortClassName);
            }
        }
    }

    /**
     * Traverses classes contained in a ZIP file input stream.
     *
     * @param zipInputStream the ZIP file input stream (must not be {@literal null})
     * @param handler the handler to process classes (must not be {@literal null})
     */

        final LanguageHelper languageHelper = ComponentUtil.getLanguageHelper();
        final List<Map<String, Object>> docList = body.documents.stream().map(doc -> {
            if (!doc.containsKey(indexFieldContentLength)) {
                long contentLength = 0;
                if (doc.get(indexFieldTitle) instanceof final String title) {

        }
    }

    /**
     * Validates that the input stream is not null.
     * This is a common validation performed by most extractors.
     *
     * @param in The input stream to validate
     * @throws CrawlerSystemException if the input stream is null
     */
    protected void validateInputStream(final InputStream in) {
        if (in == null) {