* @param first
     *            The first value
     * @param second
     *            The second value
     * @return A pair of two values
     */
    public static <T1, T2> Pair<T1, T2> pair(final T1 first, final T2 second) {
        return new Pair<>(first, second);
    }

    /**
     * Constructs an instance.
     */
    public Pair() {
    }

    /**
     * Constructs an instance.
     *

     */
    public static final int KERB_CHECKSUM_HMAC_MD5 = 0xFFFFFF76;
    /**
     * Kerberos checksum type for HMAC-SHA1-96 with AES-128.
     */
    public static final int HMAC_SHA1_96_AES128 = 0x0000000F;
    /**
     * Kerberos checksum type for HMAC-SHA1-96 with AES-256.
     */
    public static final int HMAC_SHA1_96_AES256 = 0x00000010;

    /**

        final Map<String, Object> sourceMap = super.toSource();
        if (fields != null) {
            sourceMap.putAll(fields);
        }
        return sourceMap;
    }

    @Override
    protected void addFieldToSource(final Map<String, Object> sourceMap, final String field, final Object value) {
        if (value instanceof final LocalDateTime ldt) {

   *
   * @since 10.0
   */
  public final Predicate<@Nullable T> equivalentTo(@Nullable T target) {
    return new EquivalentToPredicate<>(this, target);
  }

  private static final class EquivalentToPredicate<T>
      implements Predicate<@Nullable T>, Serializable {

    private final Equivalence<T> equivalence;
    private final @Nullable T target;

    NameQueryRequest(final Configuration config, final Name name) {
        super(config);
        this.questionName = name;
        this.questionType = NB;
    }

    @Override
    int writeBodyWireFormat(final byte[] dst, final int dstIndex) {
        return writeQuestionSectionWireFormat(dst, dstIndex);
    }

    @Override
    int readBodyWireFormat(final byte[] src, final int srcIndex) {

     */
    public static OutputStream getXContentBuilderOutputStream(final XContentBuilderCallback func, final MediaType mediaType) {
        try (final XContentBuilder builder = func.apply(mediaType.contentBuilder(), ToXContent.EMPTY_PARAMS)) {
            builder.flush();
            return builder.getOutputStream();
        } catch (final IOException e) {
            if (logger.isDebugEnabled()) {

    public static final String CHILDREN_COMBINATION_MODE_ATTRIBUTE = "combine.children";
    /** Value indicating children should be merged based on element names */
    public static final String CHILDREN_COMBINATION_MERGE = "merge";
    /** Value indicating children should be appended as siblings */
    public static final String CHILDREN_COMBINATION_APPEND = "append";
    /**

  }

  static final CharSource BROKEN_READ_SOURCE = new TestCharSource("ABC", READ_THROWS);
  static final CharSource BROKEN_CLOSE_SOURCE = new TestCharSource("ABC", CLOSE_THROWS);
  static final CharSource BROKEN_OPEN_SOURCE = new TestCharSource("ABC", OPEN_THROWS);
  static final CharSink BROKEN_WRITE_SINK = new TestCharSink(WRITE_THROWS);
  static final CharSink BROKEN_CLOSE_SINK = new TestCharSink(CLOSE_THROWS);

    public static final int NEGOTIATE_RESPONSE = 0x02;
    /** Status indicating successful negotiation */
    public static final int STATUS_SUCCESS = 0x00000000;
    /** Status indicating SMB Direct is not supported */
    public static final int STATUS_NOT_SUPPORTED = 0x00000001;
    /** Status indicating insufficient resources for SMB Direct */
    public static final int STATUS_INSUFFICIENT_RESOURCES = 0x00000002;

    public void test_store_basic() {
        // Create a simple DataStore implementation for testing
        final AtomicBoolean storeCalled = new AtomicBoolean(false);
        final AtomicReference<DataConfig> capturedConfig = new AtomicReference<>();
        final AtomicReference<IndexUpdateCallback> capturedCallback = new AtomicReference<>();
        final AtomicReference<DataStoreParams> capturedParams = new AtomicReference<>();