Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 1,030 for stream (0.18 sec)

  1. impl/maven-core/src/test/java/org/apache/maven/configuration/DefaultBeanConfiguratorPathTest.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.configuration;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.StringReader;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    
    import org.apache.maven.api.xml.XmlService;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Mar 25 09:45:07 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.crawler.Constants;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  3. src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java

            // Verify the cached files have correct names
            List<DirectoryCacheEntry.FileInfo> children = cacheEntry.getChildren();
            assertTrue(children.stream().anyMatch(f -> "file1.txt".equals(f.getName())));
            assertTrue(children.stream().anyMatch(f -> "dir1".equals(f.getName())));
        }
    
        @Test
        public void testUpdateDirectoryCache() throws IOException {
            String directoryPath = "/test/dir";
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultPluginValidationManager.java

    import java.util.LinkedHashMap;
    import java.util.LinkedHashSet;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.stream.Collectors;
    
    import org.apache.maven.api.Constants;
    import org.apache.maven.eventspy.AbstractEventSpy;
    import org.apache.maven.execution.ExecutionEvent;
    import org.apache.maven.execution.MavenSession;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sat Apr 05 11:52:32 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

     * layer primitives: connections, requests, responses, and streams.
     *
     * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest
     * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not
     * the other streams sharing its connection. But if the TLS handshake is still in progress then
     * canceling may break the entire connection.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/base/Optional.java

       * <p><b>Comparison to {@code java.util.Optional}:</b> this method has no equivalent in Java 8's
       * {@code Optional} class; use {@code
       * optionals.stream().filter(Optional::isPresent).map(Optional::get)} instead.
       *
       * <p><b>Java 9 users:</b> use {@code optionals.stream().flatMap(Optional::stream)} instead.
       *
       * @since 11.0 (generics widened in 13.0)
       */
      public static <T> Iterable<T> presentInstances(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jun 04 13:03:16 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import java.util.regex.MatchResult;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Stream;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing
     * utilities.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ImmutableBiMap.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Map;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BiMap} whose contents will never change, with many other important properties detailed
     * at {@link ImmutableCollection}.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 22.2K bytes
    - Viewed (0)
  9. tensorflow/c/c_api_macros_internal.h

    // `struct_size` is used for struct member compatibility check between core TF
    // and plug-ins with the same C API minor version. More info here:
    // https://github.com/tensorflow/community/blob/master/rfcs/20200612-stream-executor-c-api/C_API_versioning_strategy.md
    #define TF_VALIDATE_STRUCT_SIZE(STRUCT_NAME, STRUCT_OBJ, SIZE_VALUE_NAME) \
      do {                                                                    \
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Mon Mar 13 17:40:56 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/design/AdminDesignAction.java

                return null;
            }
            validate(form, messages -> {}, this::asListHtml);
            verifyTokenKeep(this::asListHtml);
            return asStream(file.getName()).contentTypeOctetStream().stream(out -> {
                try (FileInputStream fis = new FileInputStream(file)) {
                    out.write(fis);
                }
            });
        }
    
        /**
         * Delete a design file.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 17.4K bytes
    - Viewed (0)
Back to top