id = SuggestUtil.createSuggestTextId(this.text);
    }

    /**
     * Returns the text of the suggest item.
     * @return The text.
     */
    public String getText() {
        return text;
    }

    /**
     * Returns the readings of the suggest item.
     * @return The readings.
     */
    public String[][] getReadings() {
        return readings;
    }

            try {
                for (Map.Entry<String, List<MojoExecution>> fork : forkedExecutions.entrySet()) {
                    String projectId = fork.getKey();

                    ProjectIndex projectIndex = session.getSession()
                            .getData()
                            .computeIfAbsent(PROJECT_INDEX, () -> new ProjectIndex(session.getProjects()));

crawler.awaitTermination();
System.out.println("Crawling completed");
```

### Custom Content Extractor

```java
public class CustomExtractor extends AbstractExtractor {
    @Override
    public ExtractData getText(final InputStream inputStream, final Map<String, String> params) {
        // Custom extraction logic
        ExtractData extractData = new ExtractData();
        // ... implementation
        return extractData;
    }

                    "Should throw DcerpcException for missing endpoint");
        }
    }

    @Nested
    @DisplayName("Getter Method Tests")
    class GetterTests {

        @Test
        @DisplayName("Should return correct transport context")
        void testGetTransportContext() throws Exception {

            }

            // This List can be empty when the executions are already present in the plan
            if (!forkedExecutions.isEmpty()) {
                mojoExecution.setForkedExecutions(BuilderCommon.getKey(forkedProject), forkedExecutions);
            }
        }
    }

    private List<MojoExecution> calculateForkedLifecycle(
            MojoExecution mojoExecution,
            MavenSession session,

        return multimap().containsEntry(entry.getKey(), entry.getValue());
      }
      return false;
    }

    @Override
    public boolean remove(@Nullable Object o) {
      if (o instanceof Map.Entry) {
        Map.Entry<?, ?> entry = (Map.Entry<?, ?>) o;
        return multimap().remove(entry.getKey(), entry.getValue());
      }
      return false;
    }

                n++;
                final int size = chain.size();
                final int cost = chain.getCreditCost();
                final CommonServerMessageBlockRequest next = chain.getNext();
                if (log.isTraceEnabled()) {
                    log.trace(String.format("%s costs %d avail %d (%s)", chain.getClass().getName(), cost, this.credits.availablePermits(),
                            this.name));

                    .stream()
                    .sorted((e1, e2) -> e1.getValue().getLastAccessedAt().compareTo(e2.getValue().getLastAccessedAt()))
                    .limit(toRemove)
                    .map(Map.Entry::getKey)
                    .collect(Collectors.toList())
                    .forEach(sessionCache::remove);
        }
    }

    /**
     * Checks if a session is expired.
     *

    protected Object parsePrimitive(final JsonParser jsonParser) throws IOException {
        final JsonToken token = jsonParser.getCurrentToken();
        return switch (token) {
        case VALUE_STRING -> jsonParser.getText();
        case VALUE_NUMBER_INT -> jsonParser.getLongValue();
        case VALUE_NUMBER_FLOAT -> jsonParser.getDoubleValue();
        case VALUE_TRUE -> true;
        case VALUE_FALSE -> false;

        void testInitialTotalBytesWrittenValue() {
            assertEquals(0, response.getTotalBytesWritten());
        }
    }

    @Nested
    @DisplayName("Getter Tests")
    class GetterTests {

        @Test
        @DisplayName("Should get chunksWritten value")
        void testGetChunksWritten() {
            // Initial value should be 0