}

    /**
     * Refreshes the OpenSearch index to make recent changes visible for search.
     *
     * @return The RefreshResponse from OpenSearch.
     * @throws OpenSearchAccessException if the refresh operation fails.
     */
    protected RefreshResponse refresh() {
        try {
            return getClient().get(c -> c.admin().indices().prepareRefresh(index).execute());
        } catch (final Exception e) {

 */
package jcifs.internal.smb2.ioctl;

import jcifs.Decodable;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.util.SMBUtil;

/**
 * Response structure for SMB2 IOCTL pipe peek operation.
 * Provides information about data available in a named pipe.
 *
 * @author svella
 *
 */
public class SrvPipePeekResponse implements Decodable {

    /**
     * Constructs a new SrvPipePeekResponse.

    for (i in 0 until namesAndValues.size) {
      result += namesAndValues[i].length.toLong()
    }

    return result
  }

  override operator fun iterator(): Iterator<Pair<String, String>> = commonIterator()

  fun newBuilder(): Builder = commonNewBuilder()

  /**
   * Returns true if `other` is a `Headers` object with the same headers, with the same casing, in

  public void testDescendingNavigation() {
    List<Entry<E>> ascending = new ArrayList<>();
    Iterators.addAll(ascending, sortedMultiset.entrySet().iterator());
    List<Entry<E>> descending = new ArrayList<>();
    Iterators.addAll(descending, sortedMultiset.descendingMultiset().entrySet().iterator());
    Collections.reverse(descending);
    assertEquals(ascending, descending);
  }

    // For datasets of many double values created from an iterator, we test many combinations of
    // finite and non-finite values:
    for (ManyValues values : ALL_MANY_VALUES) {
      StatsAccumulator accumulator = new StatsAccumulator();
      StatsAccumulator accumulatorByAddAllStats = new StatsAccumulator();
      accumulator.addAll(values.asIterable().iterator());
      for (double value : values.asIterable()) {

                            }
                        }

                        // Conflict Resolution
                        ResolutionNode resolved = null;
                        for (Iterator<ConflictResolver> j = conflictResolvers.iterator();
                                resolved == null && j.hasNext(); ) {
                            ConflictResolver conflictResolver = j.next();

        return true;
      }

      @Override
      public int hashCode() {
        return hashCode;
      }

      @Override
      public UnmodifiableIterator<Entry<V, K>> iterator() {
        return asList().iterator();
      }

      @Override
      public void forEach(Consumer<? super Entry<V, K>> action) {
        asList().forEach(action);
      }

      @Override

    //                                               -------
    /**
     * Displays the details of a request header item.
     *
     * @param crudMode the CRUD mode for the operation
     * @param id the ID of the request header item to display
     * @return HTML response for the details page
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })

        buffer[i] = b;
        if (i == BLOCK_LENGTH - 1) {
            transform(buffer, 0);
        }
    }

    /**
     * MD4 block update operation.
     * <p>
     * Continues an MD4 message digest operation, by filling the buffer,
     * transform(ing) data in 512-bit message block(s), updating the variables
     * context and count, and leaving (buffering) the remaining bytes in buffer

        assertNotNull(nodeAddress, "Node address should not be null");
        // Note: Cannot test isGroupAddress() and getNodeType() without CIFSContext in unit test
        // These methods require network operations and are integration test material
    }

    @Test
    void readRDataWireFormat_shouldSetNbtAddress_whenAddressIsNonZero_groupNameTrue_nodeTypeNonZero()
            throws NoSuchFieldException, IllegalAccessException {