.execute()
                            .actionGet(getIndicesTimeout());
                } catch (final IOException e) {
                    throw new SuggesterException(e);
                }
            }

            final List<Tuple<String, Object>> arraySettings = new ArrayList<>();
            final Map<String, Object> defaultSettings = defaultSettings();

            purgeExpiry = expiry;
            if (throwException) {
                if (exceptionMessage != null) {
                    throw new JobProcessingException(new RuntimeException(exceptionMessage));
                }
                throw new JobProcessingException(new RuntimeException("Test exception"));
            }
            return purgeCallCount;
        }

            getMap()
                .compute(
                    k0(),
                    (k, v) -> {
                      assertEquals(k0(), k);
                      assertEquals(v0(), v);
                      throw new SomeUncheckedException();
                    }));
    expectUnchanged();
  }

  @MapFeature.Require({SUPPORTS_PUT, SUPPORTS_REMOVE})
  public void testCompute_absentFunctionThrows() {
    assertThrows(

    FutureCallback<String> callback =
        new FutureCallback<String>() {
          @Override
          public void onSuccess(String result) {
            successCalls[0]++;
            throw exception;
          }

          @Override
          public void onFailure(Throwable t) {
            failureCalls[0]++;
          }
        };
    addCallback(future, callback, directExecutor());

    bufferHelper(
        "\nempty first line\nno newline at end", "\n", "empty first line\n", "no newline at end");
    bufferHelper("three\rlines\rno newline at end", "three\r", "lines\r", "no newline at end");
    bufferHelper("mixed\nline\rendings\r\n", "mixed\n", "line\r", "endings\r\n");
  }

  private static final ImmutableSet<Integer> CHUNK_SIZES =

    bufferHelper(
        "\nempty first line\nno newline at end", "\n", "empty first line\n", "no newline at end");
    bufferHelper("three\rlines\rno newline at end", "three\r", "lines\r", "no newline at end");
    bufferHelper("mixed\nline\rendings\r\n", "mixed\n", "line\r", "endings\r\n");
  }

  private static final ImmutableSet<Integer> CHUNK_SIZES =

        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarOpenPolicy2.class));

        LsaPolicyHandle handle = new LsaPolicyHandle(mockDcerpcHandle, "server", 123);

        // Now, mock the behavior for MsrpcLsarClose to throw an error
        doAnswer(invocation -> {
            MsrpcLsarClose rpc = invocation.getArgument(0);
            rpc.retval = errorCode; // Simulate RPC error
            return null;

   * {@code ClassCastException} for any elements {@code e1} and {@code e2} in the multiset. If the
   * user attempts to add an element to the multiset that violates this constraint (for example, the
   * user attempts to add a string element to a set whose elements are integers), the {@code
   * add(Object)} call will throw a {@code ClassCastException}.
   *

                break;
            }
        } catch (final CrawlerSystemException e) {
            if (!ignoreException) {
                throw e;
            }
        } catch (final Exception e) {
            if (!ignoreException) {
                throw new CrawlerSystemException("Could not stop a process.", e);
            }
        }
    }

    /**

        try {
            JvmUtil.getJavaVersion();
            fail("Should throw NumberFormatException");
        } catch (NumberFormatException e) {
            // Expected
        }

        // Test with invalid format
        System.setProperty("java.version", "invalid");
        try {
            JvmUtil.getJavaVersion();
            fail("Should throw NumberFormatException");
        } catch (NumberFormatException e) {