nameLen, err := direntNamlen(dirent)
	if err != nil {
		return consumed, nil, typ, err
	}

	return consumed, nameBuf[:nameLen], typ, nil
}

// readDirFn applies the fn() function on each entries at dirPath, doesn't recurse into
// the directory itself, if the dirPath doesn't exist this function doesn't return
// an error.
func readDirFn(dirPath string, fn func(name string, typ os.FileMode) error) error {

import org.dbflute.optional.OptionalEntity;

/**
 * Manages a dictionary file for stemmer overrides.
 * This class handles reading, parsing, and updating files that contain
 * stemmer override rules, where each rule maps an input word to an
 * output stem. The file format is expected to be `input => output`.
 *
 * The class provides methods for retrieving, adding, updating, and

 * try block in order to catch any exception that may be thrown (including from the call to {@code
 * close()}).
 *
 * <p>This pattern ensures the following:
 *
 * <ul>
 *   <li>Each {@code Closeable} resource that is successfully registered will be closed later.
 *   <li>If a {@code Throwable} is thrown in the try block, no exceptions that occur when attempting

        // if multiple test tasks run in parallel. We also pass it to the Gradle build as a maximum (maxParallelForks)
        // for each test task, such that we are independent of whatever default value is defined in the build itself.
        "-Dorg.gradle.workers.max=$maxParallelForks",
        "-PmaxParallelForks=$maxParallelForks",

            int expected = NegTokenInit.DELEGATION | NegTokenInit.INTEGRITY | NegTokenInit.CONFIDENTIALITY;
            assertEquals(expected, init.getContextFlags());

            // Verify each flag individually
            assertTrue(init.getContextFlag(NegTokenInit.DELEGATION));
            assertTrue(init.getContextFlag(NegTokenInit.INTEGRITY));
            assertTrue(init.getContextFlag(NegTokenInit.CONFIDENTIALITY));

    }
    throw new IllegalArgumentException(
        lenientFormat("min (%s) must be less than or equal to max (%s)", min, max));
  }

  /**
   * Returns the values from each provided array combined into a single array. For example, {@code
   * concat(new float[] {a, b}, new float[] {}, new float[] {c}} returns the array {@code {a, b,
   * c}}.
   *

import okio.Buffer
import okio.ByteString
import okio.ByteString.Companion.encodeUtf8
import okio.Source
import okio.Timeout

/**
 * Replicates a single upstream source into multiple downstream sources. Each downstream source
 * returns the same bytes as the upstream source. Downstream sources may read data either as it
 * is returned by upstream, or after the upstream source has been exhausted.
 *

   * key, the choice of {@link KeyAbsentBehavior} decides which index is returned.
   *
   * <p>This method runs in log(n) time on random-access lists, which offer near-constant-time
   * access to each list element.
   *
   * @param list the list to be searched.
   * @param key the value to be searched for.
   * @param comparator the comparator by which the list is ordered.

        assertEquals(0xFFFFFFFF, ace.getAccessMask());
    }

    @Test
    @DisplayName("Test all flag combinations for inheritance")
    void testAllFlagCombinationsForInheritance() {
        // Test each individual flag
        ace.flags = ACE.FLAGS_OBJECT_INHERIT;
        assertFalse(ace.isInherited());

        ace.flags = ACE.FLAGS_CONTAINER_INHERIT;
        assertFalse(ace.isInherited());

        // since not all tests need this stub
        lenient().when(mockConfig.getOemEncoding()).thenReturn("UTF-8");

        // Initialize NameQueryResponse before each test
        nameQueryResponse = new NameQueryResponse(mockConfig);
    }

    @Test
    void constructor_shouldInitializeRecordName() throws NoSuchFieldException, IllegalAccessException {