Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 1,233 for jstream (0.05 seconds)

  1. android/guava-tests/test/com/google/common/collect/CollectSpliteratorsTest.java

    import com.google.common.collect.testing.SpliteratorTester;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Spliterator;
    import java.util.stream.DoubleStream;
    import java.util.stream.IntStream;
    import java.util.stream.LongStream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullMarked;
    
    /** Tests for {@code CollectSpliterators}. */
    @GwtCompatible
    @NullMarked
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  2. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsWriter.java

        void write(Writer output, Map<String, Object> options, Settings settings) throws IOException;
    
        /**
         * Writes the supplied settings to the specified byte stream. The stream will be automatically closed before the
         * method returns.
         *
         * @param output The stream to serialize the settings to, must not be {@code null}.
         * @param options The options to use for serialization, may be {@code null} to use the default values.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  3. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java

    import java.io.IOException;
    import java.nio.file.Files;
    import java.nio.file.attribute.PosixFileAttributeView;
    import java.nio.file.attribute.PosixFilePermission;
    import java.util.List;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import org.apache.tools.ant.taskdefs.condition.Os;
    import org.gradle.api.DefaultTask;
    import org.gradle.api.GradleException;
    import org.gradle.api.file.FileCollection;
    import org.gradle.api.file.FileTree;
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3.9K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java

        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initializing {}", this.getClass().getSimpleName());
            }
            stream(ComponentUtil.getFessConfig().getSearchDefaultPermissionsAsArray()).of(stream -> stream.forEach(name -> {
                defaultRoleList.add(name);
            }));
        }
    
        /**
         * Builds a set of roles from the request.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/SessionSetupHandlerTest.java

    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.verifyNoInteractions;
    
    import java.lang.reflect.Modifier;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  6. internal/config/crypto_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    		data, err := io.ReadAll(ciphertext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    
    		plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/dict/synonym/AdminDictSynonymAction.java

         * @return ActionResponse with the file download stream
         */
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse download(final DownloadForm form) {
            validate(form, messages -> {}, () -> downloadpage(form.dictId));
            verifyTokenKeep(() -> downloadpage(form.dictId));
            return synonymService.getSynonymFile(form.dictId)
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 23.7K bytes
    - Click Count (1)
  8. src/main/java/org/codelibs/fess/entity/FacetInfo.java

            if (StringUtil.isNotBlank(fessConfig.getQueryFacetFields())) {
                field = StreamUtil.split(fessConfig.getQueryFacetFields(), ",")
                        .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).distinct().toArray(n -> new String[n]));
            }
            if (StringUtil.isNotBlank(fessConfig.getQueryFacetFieldsSize())) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/Location.java

         */
        int getColumnNumber();
    
        /**
         * Return the byte or character offset into the input source this location
         * is pointing to. If the input source is a file or a byte stream then
         * this is the byte offset into that stream, but if the input source is
         * a character media then the offset is the character offset.
         * Returns -1 if there is no offset available.
         * @return the current offset
         */
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Mar 25 10:50:01 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelper.java

            if (StringUtil.isNotBlank(overrides)) {
                final Map<String, String> map = new LinkedHashMap<>();
                StreamUtil.split(overrides, "\n").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(s -> {
                    final String[] values = StringUtils.split(s, "=", 2);
                    if (values.length == 2) {
                        map.put(values[0].trim(), values[1].trim());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 24 09:06:33 GMT 2026
    - 2.7K bytes
    - Click Count (0)
Back to Top