Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 848 for Streams (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/collect/CompactHashMap.java

      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeInt(size());
        Iterator<Entry<K, V>> entryIterator = entrySetIterator();
        while (entryIterator.hasNext()) {
          Entry<K, V> e = entryIterator.next();
          stream.writeObject(e.getKey());
          stream.writeObject(e.getValue());
        }
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 39.6K bytes
    - Click Count (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/AbstractExtractor.java

            }
        }
    
        /**
         * Validates that the input stream is not null.
         * This is a common validation performed by most extractors.
         *
         * @param in The input stream to validate
         * @throws CrawlerSystemException if the input stream is null
         */
        protected void validateInputStream(final InputStream in) {
            if (in == null) {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Wed Nov 19 08:55:01 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  3. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultBuildResumptionDataRepository.java

    import java.io.IOException;
    import java.io.Reader;
    import java.io.Writer;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.Properties;
    import java.util.stream.Stream;
    
    import org.apache.maven.project.MavenProject;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 11 16:38:19 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java

        public Type require(String id) {
            requireNonNull(id, "id cannot be null");
            return usedTypes.computeIfAbsent(id, i -> {
                Type type = lookup.lookupList(TypeProvider.class).stream()
                        .flatMap(p -> p.provides().stream())
                        .filter(t -> Objects.equals(id, t.id()))
                        .findFirst()
                        .orElse(null);
                if (type == null) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed May 14 04:47:58 GMT 2025
    - 4K bytes
    - Click Count (0)
  5. compat/maven-model/src/test/java/org/apache/maven/model/v4/Xpp3DomPerfTest.java

     * under the License.
     */
    package org.apache.maven.model.v4;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.List;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.maven.api.model.InputSource;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/ShareEnumIteratorTest.java

    import static org.mockito.Mockito.when;
    
    import java.net.MalformedURLException;
    import java.util.Arrays;
    import java.util.Collections;
    import java.util.Iterator;
    import java.util.List;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/notify/Smb2ChangeNotifyRequest.java

        /**
         * Notify when alternate data stream name changes
         */
        public static final int FILE_NOTIFY_CHANGE_STREAM_NAME = 0x200;
        /**
         * Notify when alternate data stream size changes
         */
        public static final int FILE_NOTIFY_CHANGE_STREAM_SIZE = 0x400;
        /**
         * Notify when alternate data stream is written
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/util/MimeMap.java

        }
    
        /**
         * Returns the MIME type for the given file extension.
         * If no mapping is found, returns "application/octet-stream" as the default.
         *
         * @param extension the file extension to look up (without the dot)
         * @return the MIME type for the extension, or "application/octet-stream" if not found
         * @throws IOException if there is an error processing the MIME mappings
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/plugin/PluginResolutionException.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.plugin;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.maven.model.Plugin;
    
    /**
     * Exception occurring trying to resolve a plugin.
     *
     */
    public class PluginResolutionException extends Exception {
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

       *   holdsLock assertions.
       *
       * - For stream() and spliterator(), we have to forward to the delegate ourselves because
       *   ForwardingSet does not forward `default` methods, as discussed in its Javadoc.
       */
    
      // Currently, we don't include stream() and spliterator() for our classes in the Android flavor.
    
      @Override
      public boolean remove(@Nullable Object o) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.3K bytes
    - Click Count (0)
Back to Top