import java.util.stream.Stream;
import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;

/**
 * An assortment of mainly legacy static utility methods that operate on or return objects of type
 * {@code Iterable}. Except as noted, each method has a corresponding {@link Iterator}-based method
 * in the {@link Iterators} class.
 *

import java.util.Iterator;
import java.util.List;
import java.util.NoSuchElementException;
import java.util.Objects;
import java.util.PriorityQueue;
import java.util.Queue;
import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;

/**
 * This class contains static utility methods that operate on or return objects of type {@link
 * Iterator}. Except as noted, each method has a corresponding {@link Iterable}-based method in the

        }

        // Replace the info.e field with our populated array
        setDfsEnumArray(dfsRootEnum, populatedArray);

        // Test getEntries returns correct SmbShareInfo objects
        FileEntry[] entries = dfsRootEnum.getEntries();
        assertNotNull(entries);
        assertEquals(3, entries.length);

        // Verify each entry
        for (int i = 0; i < 3; i++) {

import jcifs.NetbiosAddress;
import jcifs.smb.NtlmPasswordAuthentication;

/**
 * JUnit 5 tests for the NtlmSsp class.
 * This class uses Mockito to simulate HttpServletRequest and HttpServletResponse objects.
 */
@ExtendWith(MockitoExtension.class)
public class NtlmSspTest {

    @Mock
    private CIFSContext mockCifsContext;

    @Mock
    private Configuration mockConfig;

    @Mock

 * OutOfMemoryError}). This class does not permit {@code null} elements. A priority queue relying on
 * {@linkplain Comparable natural ordering} also does not permit insertion of non-comparable objects
 * (doing so results in {@code ClassCastException}).
 *
 * <p>This class and its iterator implement all of the optional methods of the {@link

        assertEquals(DialectVersion.SMB311, config.getMaximumVersion());
    }

    @Test
    @DisplayName("Test initProtocolVersions with DialectVersion objects")
    void testInitProtocolVersionsWithDialectVersions() {
        config.initProtocolVersions(DialectVersion.SMB210, DialectVersion.SMB300);

        assertEquals(DialectVersion.SMB210, config.getMinimumVersion());

      this.hasResponseHeaders = true
      if (outFinished) {
        this.sink.finished = true
        notifyAll() // Because doReadTimeout() may have changed.
      }
    }

    // Only DATA frames are subject to flow-control. Transmit the HEADER frame if the connection
    // flow-control window is fully depleted.
    if (!flushHeaders) {
      withLock {

  - *apiserver_cache_list_fetched_objects_total*: Counter of objects read from watch cache in the course of serving a LIST request, broken down by resource_prefix and index_name
  - *apiserver_cache_list_evaluated_objects_total*: Counter of objects tested in the course of serving a LIST request from watch cache, broken down by resource_prefix

 * @since 11.0
 */
public final class Hashing {
  /**
   * Returns a general-purpose, <b>temporary-use</b>, non-cryptographic hash function. The algorithm
   * the returned function implements is unspecified and subject to change without notice.
   *
   * <p><b>Warning:</b> a new random seed for these functions is chosen each time the {@code
   * Hashing} class is loaded. <b>Do not use this method</b> if hash codes may escape the current

import org.opensearch.index.query.QueryBuilders;
import org.opensearch.search.sort.SortOrder;

/**
 * Command class for handling term query execution and conversion.
 * This class processes Lucene TermQuery objects and converts them to OpenSearch QueryBuilder instances.
 */
public class TermQueryCommand extends QueryCommand {
    private static final Logger logger = LogManager.getLogger(TermQueryCommand.class);

    /**