/**
     * Sent by the server to indicate that the server and client are
     * on the same machine. This implies that the server will include
     * a local security context handle in the Type 2 message, for
     * use in local authentication.
     */
    int NTLMSSP_NEGOTIATE_LOCAL_CALL = 0x00004000;

    /**
     * Indicates that authenticated communication between the client

 */
@GwtCompatible
@IgnoreJRERequirement // Users will use this only if they're already using streams.
public final class MoreCollectors {

  /*
   * TODO(lowasser): figure out if we can convert this to a concurrent AtomicReference-based
   * collector without breaking j2cl?
   */
  private static final Collector<Object, ?, Optional<Object>> TO_OPTIONAL =
      Collector.of(
          ToOptionalState::new,

            return queryHelper.build(searchRequestType, query, context -> {
                if (SearchRequestType.ADMIN_SEARCH.equals(searchRequestType)) {
                    context.skipRoleQuery();
                } else if (similarDocHash != null) {
                    final DocumentHelper documentHelper = ComponentUtil.getDocumentHelper();
                    context.addQuery(boolQuery -> {

**Principles:**
- Avoid over-engineering - keep solutions simple
- Only expose necessary public APIs
- Validate parameters with `Objects.requireNonNull()`
- Provide detailed error messages with context
- Add logging with contextual information

### Resource Files

- `src/main/resources/suggest_indices/suggest.json` - Index settings

    @Override
    public Kerb5Authenticator clone() {
        JAASAuthenticator auth = new JAASAuthenticator();
        cloneInternal(auth, this);
        return auth;
    }

    /**
     * Clone the context
     *
     * @param to the target authenticator
     * @param from the source authenticator
     */
    protected static void cloneInternal(JAASAuthenticator to, JAASAuthenticator from) {

   * exceptions thrown from the test do not cause this check to fail.
   */
  @RegisterExtension
  val noDataLeftBehind =
    AfterEachCallback { context: ExtensionContext ->
      if (context.executionException.isPresent) return@AfterEachCallback
      assertThat(data.readByteString().hex(), "Data not empty")
        .isEqualTo("")
    }

        return asJson(new ApiResponse().status(Status.OK).result());
    }

    /**
     * Creates an EditBody from a RelatedQuery entity for API responses.
     *
     * @param entity the RelatedQuery entity to convert
     * @return EditBody containing the entity data formatted for editing
     */
    protected EditBody createEditBody(final RelatedQuery entity) {
        final EditBody body = new EditBody();

        }

        return true;
    }

    /**
     * Deletes the scroll context associated with the given scroll ID.
     *
     * @param client the OpenSearch client used to clear the scroll context
     * @param scrollId the ID of the scroll context to be deleted; if null, no action is taken
     */
    public static void deleteScrollContext(final Client client, final String scrollId) {

     * @param inOff the offset into the input array
     * @param outInts the output integer array
     * @param outOff the offset into the output array
     * @param intLen the number of integers to convert
     */
    public static void squashBytesToInts(final byte[] inBytes, final int inOff, final int[] outInts, final int outOff, final int intLen) {

        for (int i = 0; i < intLen; ++i) {

    private final SmbPipeHandleInternal handle;

    /**
     * Creates a DCERPC pipe handle for named pipe communication
     * @param url the DCERPC URL specifying the endpoint
     * @param tc the CIFS context for connection configuration
     * @param unshared whether to use an exclusive connection
     * @throws DcerpcException if DCERPC initialization fails
     * @throws MalformedURLException if the URL is malformed
     */