this.handle = handle;
        if (server == null) {
            server = "\\\\";
        }
        final MsrpcLsarOpenPolicy2 rpc = new MsrpcLsarOpenPolicy2(server, access, this);
        handle.sendrecv(rpc);
        if (rpc.retval != 0) {
            throw new SmbException(rpc.retval, false);
        }
    }

    /**
     * Closes the LSA policy handle.
     *

    private PagerCreator pagerCreator;
    private NamingConvention namingConvention;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        namingConvention = new MockNamingConvention();
        pagerCreator = new PagerCreator(namingConvention);
    }

    // Test constructor initialization
    public void test_constructor() {
        // Verify suffix is set correctly

 * </p>
 *
 * <p>
 * Example usage:
 * </p>
 *
 * <pre>
 * {@code
 * try (InputStream in = new FileInputStream("example.pdf")) {
 *     ExtractData extractData = new ExtractorBuilder(crawlerContainer, in, new HashMap<>())
 *         .mimeType("application/pdf")
 *         .filename("example.pdf")
 *         .maxContentLength(1024 * 1024)
 *         .extract();
 *

     */
    protected List<OnConnectListener> onConnectListenerList = new ArrayList<>();

    /**
     * Flag indicating whether the client is connected.
     */
    private volatile boolean connected;

    /**
     * Scroll for delete operations.
     */
    protected Scroll scrollForDelete = new Scroll(TimeValue.timeValueMinutes(1));

    /**
     * Size for delete operations.

    @Nullable
    Predicate<PathType> getPathTypeFilter();

    @Nullable
    List<RemoteRepository> getRepositories();

    @Nonnull
    static DependencyResolverRequestBuilder builder() {
        return new DependencyResolverRequestBuilder();
    }

    @Nonnull
    static DependencyResolverRequest build(Session session, RequestType requestType, Artifact rootArtifact) {

  private void readObject(ObjectInputStream stream) throws InvalidObjectException {
    throw new InvalidObjectException("Use SerializedForm");
  }

  @Override
  @J2ktIncompatible
  @GwtIncompatible
    Object writeReplace() {
    return new SerializedForm(toArray());
  }

  /**
   * Returns a new builder. The generated builder is equivalent to the builder created by the {@link
   * Builder} constructor.

        assertEquals(CronExpressionValidator.class, validators[0]);
    }

    // Test validation with valid cron expressions
    public void test_validCronExpressions() {
        TestBean bean = new TestBean();

        // Test null value (should be valid)
        bean.setCronExpression(null);
        Set<ConstraintViolation<TestBean>> violations = validator.validate(bean);
        assertTrue(violations.isEmpty());

  }

  public void testLenientFormat_badArgumentToString_gwtFriendly() {
    assertThat(Strings.lenientFormat("boiler %s plate", new ThrowsOnToString()))
        .matches("boiler <.*> plate");
  }

  private static class ThrowsOnToString {
    @Override
    public String toString() {
      throw new UnsupportedOperationException();
    }
  }

  @J2ktIncompatible
  @GwtIncompatible // NullPointerTester

    }

    /**
     * Generates a new index name with timestamp suffix.
     *
     * @param configIndex the base index configuration name
     * @return the generated index name with timestamp
     */
    protected String generateNewIndexName(final String configIndex) {
        return configIndex + "." + new SimpleDateFormat(Constants.DOCUMENT_INDEX_SUFFIX_PATTERN).format(new Date());
    }

    /**

  }

  public void testListenersNotifiedOnError() throws Exception {
    CountDownLatch successLatch = new CountDownLatch(1);
    CountDownLatch listenerLatch = new CountDownLatch(1);

    ExecutorService exec = newCachedThreadPool();

    future.addListener(listenerLatch::countDown, exec);

    new Thread(
            () -> {
              assertThrows(CancellationException.class, future::get);