Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 1,030 for stream (1.04 sec)

  1. src/test/java/jcifs/internal/smb1/com/SmbComSeekResponseTest.java

         * Provides test cases for {@link SmbComSeekResponse#readParameterWordsWireFormat(byte[], int)}.
         * @return a stream of {@link Arguments} objects containing an integer
         *         value and the corresponding little-endian byte array.
         */
        static java.util.stream.Stream<Arguments> int32Provider() {
            return java.util.stream.Stream.of(Arguments.of(0x00000000, new byte[] { 0x00, 0x00, 0x00, 0x00 }),
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. src/test/java/jcifs/EncodableTest.java

    package jcifs;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    import static org.junit.jupiter.api.Assertions.assertThrows;
    
    import java.util.Arrays;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.Arguments;
    import org.junit.jupiter.params.provider.MethodSource;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/DependencyScope.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.api;
    
    import java.util.Collections;
    import java.util.Map;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.annotations.Immutable;
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Mar 19 14:33:26 UTC 2025
    - 4K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/extension/internal/CoreExports.java

    import java.util.Map;
    import java.util.Set;
    
    import org.codehaus.plexus.classworlds.realm.ClassRealm;
    
    import static java.util.function.Function.identity;
    import static java.util.stream.Collectors.collectingAndThen;
    import static java.util.stream.Collectors.toMap;
    
    /**
     * Provides information about artifacts (identified by groupId:artifactId string key) and classpath elements exported by
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

                final String[] oldLabels = DocumentUtil.getValue(dataMap, fessConfig.getIndexFieldLabel(), String[].class);
                StreamUtil.stream(oldLabels).of(stream -> stream.forEach(newLabelSet::add));
                matchedLabelSet.stream().forEach(newLabelSet::add);
                dataMap.put(fessConfig.getIndexFieldLabel(), newLabelSet.toArray(new String[newLabelSet.size()]));
            }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ImmutableList.java

       * ImmutableSortedSet.copyOf(elements)}; if you want a {@code List} you can use its {@code
       * asList()} view.
       *
       * <p><b>Java 8+ users:</b> If you want to convert a {@link java.util.stream.Stream} to a sorted
       * {@code ImmutableList}, use {@code stream.sorted().collect(toImmutableList())}.
       *
       * @throws NullPointerException if any element in the input is null
       * @since 21.0
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                stream(parameter.getSuggestFields()).of(stream -> stream.forEach(builder::addField));
                roleQueryHelper.build(SearchRequestType.SUGGEST).stream().forEach(builder::addRole);
                builder.setSize(parameter.getNum());
                stream(langs).of(stream -> stream.forEach(builder::addLang));
    
                stream(parameter.getTags()).of(stream -> stream.forEach(builder::addTag));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 55.4K bytes
    - Viewed (1)
  8. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeTest.java

    import static org.junit.jupiter.api.Assertions.assertNotNull;
    import static org.junit.jupiter.api.Assertions.assertNull;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/CharSourceTest.java

    import java.io.IOException;
    import java.io.Reader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.util.ArrayList;
    import java.util.EnumSet;
    import java.util.List;
    import java.util.stream.Stream;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for the default implementations of {@code CharSource} methods.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

                    executeCallbacks.add(callback);
                }
            }
            if (executeCallbacks.size() > 0) {
                try {
                    executeCallbacks.stream().forEach(callback -> callback.accept(response));
                } catch (final Exception ignore) {}
            }
            latch.countDown();
        }
    
        /**
         * Rejects the deferred computation with the given throwable.
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 7.8K bytes
    - Viewed (0)
Back to top