if (in == null) {
            throw new CrawlerSystemException("LHA archive input stream is null. Cannot extract text from null input.");
        }

        final MimeTypeHelper mimeTypeHelper = getMimeTypeHelper();
        final ExtractorFactory extractorFactory = getExtractorFactory();
        final StringBuilder buf = new StringBuilder(1000);

        File tempFile = null;

        AccessTokenCQ cq = new AccessTokenCQ();
        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            AccessTokenCA ca = new AccessTokenCA();
            aggsLambda.callback(ca);

        JobLogCQ cq = new JobLogCQ();
        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            JobLogCA ca = new JobLogCA();
            aggsLambda.callback(ca);

        final String[] loggerNames = loggerNamePrefix != null
                ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n])
                : new String[0];
        return new ErrorToWarnRewritePolicy(loggerNames);
    }

import okio.Okio;
import okio.Source;

public final class Progress {

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("https://publicobject.com/helloworld.txt")
        .build();

    final ProgressListener progressListener = new ProgressListener() {
      boolean firstUpdate = true;

      @Override public void update(long bytesRead, long contentLength, boolean done) {

    public MavenExecutionPlan calculateExecutionPlan(MavenSession session, String... tasks) {
        return new MavenExecutionPlan(null, new DefaultLifecycles());
    }

    @Override
    public MavenExecutionPlan calculateExecutionPlan(MavenSession session, boolean setup, String... tasks) {
        return new MavenExecutionPlan(null, new DefaultLifecycles());
    }

    @Override
    public void execute(MavenSession session) {}

                if (is == null) {
                    throw new IOException("Resource not found: non/existent/resource.json");
                }
                // This line should not be reached
                new String(is.readAllBytes(), StandardCharsets.UTF_8);
                fail("Should throw IOException for missing resource");
            }

        Graph graph1 = new Graph();
        addEdge(graph1, "a", "b");
        addEdge(graph1, "b", "c");
        List<String> expected1 = new ArrayList<>();
        expected1.add("c");
        expected1.add("b");
        expected1.add("a");
        List<String> actual1 = graph1.visitAll();
        assertEquals(expected1, actual1);

        Graph graph2 = new Graph();
        graph2.addVertex("a");

    void testWriteBytesWireFormatWithEmptyToken() throws Exception {
        // Given
        byte[] emptyToken = new byte[0];
        Smb2SessionSetupRequest req =
                new Smb2SessionSetupRequest(mockContext, TEST_SECURITY_MODE, TEST_CAPABILITIES, TEST_PREVIOUS_SESSION_ID, emptyToken);
        byte[] buffer = new byte[512];

        // When
        req.encode(buffer, 0);

        // Then

        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch endLatch = new CountDownLatch(2);
        final AtomicInteger successCount = new AtomicInteger(0);

        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    startLatch.await();