return new SuggestIndexResponse(items.length, items.length, result.getFailures(), System.currentTimeMillis() - start);
        } catch (final Exception e) {
            throw new SuggestIndexException("Failed to write items[" + items.length + "] to " + index, e);
        }
    }

    /**
     * Deletes a suggest item by ID.
     * @param id The ID of the item to delete.

            throws ArtifactResolutionException, ArtifactNotFoundException {
        if (Artifact.RELEASE_VERSION.equals(artifact.getVersion())) {
            try {
                String version = resolveVersion(artifact, request);

                if (Artifact.RELEASE_VERSION.equals(version)) {

         * the user calls remove().)
         */
        return iterator.hasNext() || iterable.iterator().hasNext();
      }

      @Override
      @ParametricNullness
      public T next() {
        if (!iterator.hasNext()) {
          iterator = iterable.iterator();
          if (!iterator.hasNext()) {
            throw new NoSuchElementException();
          }

    if (assets == null) {
      if (Build.FINGERPRINT == null) {
        throw IOException(
          "Platform applicationContext not initialized. " +
            "Possibly running Android unit test without Robolectric. " +
            "Android tests should run with Robolectric " +
            "and call OkHttp.initialize before test",
        )
      } else {
        throw IOException(
          "Platform applicationContext not initialized. " +

            @Override
            public void deleteBefore(long time) {
                throw new RuntimeException("Crawling error");
            }
        };

        SearchLogService searchLogService = new SearchLogService() {
            @Override
            public void deleteBefore(int days) {
                throw new RuntimeException("Search error");
            }
        };

        assertTrue(flag.get());
    }

    public void test_shutdownListener_exceptionHandling() {
        // Test exception thrown in shutdown listener
        jobExecutor.addShutdownListener(new ShutdownListener() {
            @Override
            public void onShutdown() {
                throw new RuntimeException("Test exception");
            }
        });

        try {
            jobExecutor.shutdown();

                }
                if (!foundKerberos) {
                    throw new SmbUnsupportedOperationException("Server does not support kerberos authentication");
                }
            }
        } catch (SmbException e) {
            throw e;
        } catch (IOException e1) {
            log.debug("Ignoring invalid initial token", e1);
        }

        try {

            .findVirtual(clazz, "update", MethodType.methodType(void.class, ByteBuffer.class));
      } catch (ClassNotFoundException e) {
        throw new AssertionError(e);
      } catch (IllegalAccessException e) {
        // That API is public.
        throw newLinkageError(e);
      } catch (NoSuchMethodException e) {
        // Only introduced in Java 9.
        return null;
      }
    }

    }

    public void test_register_with_null_scheduledJob() {
        try {
            jobHelper.register((ScheduledJob) null);
            fail("Should throw ScheduledJobException");
        } catch (ScheduledJobException e) {
            assertEquals("No job.", e.getMessage());
        } catch (Exception e) {
            // Expected due to missing dependencies in test environment
            assertTrue(true);
        }
    }

        verifyNoMoreInteractions(smbFile);
    }

    @Test
    @DisplayName("accept: propagates SmbException thrown by dependency")
    void accept_propagatesSmbException() throws Exception {
        // Arrange: filter delegates to isDirectory which may throw SmbException
        SmbFileFilter filter = f -> f.isDirectory();
        SmbException boom = new SmbException("io error");