}

  public void testFailStart() throws Exception {
    Service a = new NoOpService();
    Service b = new FailStartService();
    Service c = new NoOpService();
    Service d = new FailStartService();
    Service e = new NoOpService();
    ServiceManager manager = new ServiceManager(asList(a, b, c, d, e));
    RecordingListener listener = new RecordingListener();
    manager.addListener(listener, directExecutor());

    HashCode expectedHash = sha512().hashBytes(new byte[] {'m', 's'});
    HashingInputStream in = new HashingInputStream(sha512(), buffer);

    long numOfByteSkipped = in.skip(2);
    assertEquals(2, numOfByteSkipped);

    byte[] buf = new byte[4];
    int numOfByteRead = in.read(buf, 0, buf.length);
    assertEquals(2, numOfByteRead);

    assertEquals(expectedHash, in.hash());
  }

    HashCode expectedHash = sha512().hashBytes(new byte[] {'m', 's'});
    HashingInputStream in = new HashingInputStream(sha512(), buffer);

    long numOfByteSkipped = in.skip(2);
    assertEquals(2, numOfByteSkipped);

    byte[] buf = new byte[4];
    int numOfByteRead = in.read(buf, 0, buf.length);
    assertEquals(2, numOfByteRead);

    assertEquals(expectedHash, in.hash());
  }

        SuggestItem[] items = new SuggestItem[1];
        String[][] readings = new String[1][];
        readings[0] = new String[] { "test" };
        items[0] = new SuggestItem(new String[] { "test" }, readings, new String[] { "content" }, 1, 0, -1, new String[] { "tag1" },
                new String[] { SuggestConstants.DEFAULT_ROLE }, new String[] { "en" }, SuggestItem.Kind.DOCUMENT);

        IllegalStateException innerException = new IllegalStateException("Invalid state");
        OutOfMemoryError middleError = new OutOfMemoryError("Memory exhausted");
        // Note: OutOfMemoryError constructor doesn't accept cause, so we create a wrapper
        RuntimeException outerException = new RuntimeException("Wrapper", middleError);
        SsoProcessException exception = new SsoProcessException(message, outerException);

                new SessionRequestPacket(mockConfig, new TestNetbiosName("SERVER", 0x20, null), new TestNetbiosName("CLIENT", 0x00, null));

        byte[] buffer = new byte[256];
        int written = writePacket.writeTrailerWireFormat(buffer, 0);

        ByteArrayInputStream bais = new ByteArrayInputStream(buffer, 0, written);
        SessionRequestPacket readPacket = new SessionRequestPacket(mockConfig);

        super.setUp(testInfo);
        crawler = new Crawler();

        // Initialize mock components
        searchEngineClient = new SearchEngineClient() {
            // Mock implementation
        };
        crawler.searchEngineClient = searchEngineClient;

        webFsIndexHelper = new WebFsIndexHelper() {
            @Override

    Supplier<Integer> supplier = new CountingSupplier();
    Function<@Nullable Object, Integer> function = Functions.forSupplier(supplier);

    assertEquals(1, (int) function.apply(null));
    assertEquals(2, (int) function.apply("foo"));

    new EqualsTester()
        .addEqualityGroup(function, Functions.forSupplier(supplier))
        .addEqualityGroup(Functions.forSupplier(new CountingSupplier()))

    Type type = new TypeCapture<T[]>() {}.capture();
    assertVisited(type);
    new BaseTypeVisitor() {
      @Override
      void visitGenericArrayType(GenericArrayType t) {}
    }.visit(type);
  }

  public <T> void testVisitParameterizedType() {
    Type type = new TypeCapture<Iterable<T>>() {}.capture();
    assertVisited(type);
    new BaseTypeVisitor() {
      @Override

        // ## Arrange ##
        final AtomicInteger onConnectReadTimeout = new AtomicInteger(-1);
        final TimeoutRecordingMockHttpURLConnection[] mockHolder = new TimeoutRecordingMockHttpURLConnection[1];
        CurlRequest req = new OpenOverrideCurlRequest(Curl.Method.GET, "http://dummy", u -> {
            TimeoutRecordingMockHttpURLConnection mock = new TimeoutRecordingMockHttpURLConnection(u);
            mockHolder[0] = mock;