Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 521 - 530 of 950 for stream (0.12 seconds)

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

  1. android/guava/src/com/google/common/collect/ImmutableEnumSet.java

      @Override
      @J2ktIncompatible // serialization
      Object writeReplace() {
        return new EnumSerializedForm<E>(delegate);
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /*
       * This class is used to serialize ImmutableEnumSet instances.
       */
      @J2ktIncompatible // serialization
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java

    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.function.Function;
    import java.util.function.Supplier;
    import java.util.stream.Collectors;
    
    import com.google.inject.AbstractModule;
    import com.google.inject.Binder;
    import com.google.inject.name.Names;
    import com.google.inject.spi.ProviderInstanceBinding;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 16:01:38 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  3. 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.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 23 23:57:26 GMT 2026
    - 20.1K bytes
    - Click Count (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocScanner.java

    import java.io.IOException;
    import java.io.StringReader;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    
    /**
     * Extracts the main description of a javadoc comment from its raw text, as a stream of characters. See
     * http://download.oracle.com/javase/1.5.0/docs/tooldocs/solaris/javadoc.html#documentationcomments for details.
     *
     * <ul>
     * <li>Removes leading '*' characters.</li>
     * <li>Removes block tags.</li>
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 4.3K bytes
    - Click Count (0)
  5. internal/dsync/dsync-client_test.go

    		TLSHandshakeTimeout:   15 * time.Second,
    		ExpectContinueTimeout: 15 * time.Second,
    		// Go net/http automatically unzip if content-type is
    		// gzip disable this feature, as we are always interested
    		// in raw stream.
    		DisableCompression: true,
    	}
    
    	return &ReconnectRESTClient{
    		u:    u,
    		rest: rest.NewClient(u, tr, nil),
    	}
    }
    
    // Close closes the underlying socket file descriptor.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Click Count (0)
  6. 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;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/ImmutableSet.java

       * the stream contains duplicates (according to {@link Object#equals(Object)}), only the first
       * duplicate in encounter order will appear in the result.
       *
       * @since 33.2.0 (available since 21.0 in guava-jre)
       */
      @IgnoreJRERequirement // Users will use this only if they're already using streams.
      public static <E> Collector<E, ?, ImmutableSet<E>> toImmutableSet() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Oct 11 14:54:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  8. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

    package gradlebuild.docs.dsl.docbook;
    
    import java.util.HashMap;
    import java.util.Locale;
    import java.util.Map;
    import java.util.regex.Pattern;
    
    /**
     * Converts the main description of a javadoc comment into a stream of tokens.
     */
    class BasicJavadocLexer implements JavadocLexer {
        private static final Pattern HTML_ELEMENT = Pattern.compile("(?s)<\\\\?[^<]+?>");
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Aug 19 15:07:24 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.apache.lucene.search.TotalHits.Relation;
    import org.codelibs.core.collection.ArrayUtil;
    import org.codelibs.core.concurrent.CommonPoolUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.fess.Constants;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 25 02:13:14 GMT 2025
    - 28K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/FrameLogTest.kt

    import okhttp3.internal.http2.Http2.formatFlags
    import okhttp3.internal.http2.Http2.frameLog
    import okhttp3.internal.http2.Http2.frameLogWindowUpdate
    import org.junit.jupiter.api.Test
    
    class FrameLogTest {
      /** Real stream traffic applied to the log format.  */
      @Test
      fun exampleStream() {
        assertThat(frameLog(false, 0, 5, TYPE_SETTINGS, FLAG_NONE))
          .isEqualTo(">> 0x00000000     5 SETTINGS      ")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 5.9K bytes
    - Click Count (0)
Back to Top