Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 881 - 890 of 1,233 for jstream (0.05 seconds)

  1. src/main/java/org/codelibs/fess/util/JvmUtil.java

         */
        public static String[] filterJvmOptions(final String[] values) {
            final int version = getJavaVersion();
            return Arrays.stream(values).map(s -> {
                final Matcher matcher = VERSION_PREFIX_PATTERN.matcher(s);
                if (!matcher.matches()) {
                    return s;
                }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  2. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          }
        }
      }
    
      private fun ResponseBody.isEventStream(): Boolean {
        val contentType = contentType() ?: return false
        return contentType.type == "text" && contentType.subtype == "event-stream"
      }
    
      override fun onFailure(
        call: Call,
        e: IOException,
      ) {
        listener.onFailure(this, e, null)
      }
    
      override fun request(): Request = request
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Oct 03 07:51:20 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/base/Converter.java

     *       converter.reverse().convertAll(bs)}.
     *   <li>Use {@code converter} or {@code converter.reverse()} anywhere a {@link
     *       java.util.function.Function} is accepted (for example {@link java.util.stream.Stream#map
     *       Stream.map}).
     *   <li><b>Do not</b> call {@link #doForward} or {@link #doBackward} directly; these exist only to
     *       be overridden.
     * </ul>
     *
     * <h3>Example</h3>
     *
     * {@snippet :
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jun 18 21:43:06 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/ImmutableEnumMap.java

      @Override
      @J2ktIncompatible // serialization
      Object writeReplace() {
        return new EnumSerializedForm<>(delegate);
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use EnumSerializedForm");
      }
    
      /*
       * This class is used to serialize ImmutableEnumMap instances.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/EmptyContiguousSet.java

      @J2ktIncompatible
        @Override
      Object writeReplace() {
        return new SerializedForm<>(domain);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // NavigableSet
      @Override
      ImmutableSortedSet<C> createDescendingSet() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/util/mime.map

    application/mac-binhex40       hqx              # Macintosh binhexed archives
    application/mspowerpoint       ppt              # Microsoft Powerpoint
    application/msword             doc              # Microsoft Word
    application/octet-stream       bin exe ani      # Binary File
    application/oda                oda
    application/pagemaker          pm5 pt5 pm       # PageMaker
    application/pdf                pdf              # Adobe Acrobat
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 5.9K bytes
    - Click Count (0)
  7. docs/smb3-features/03-multi-channel-design.md

            return channels.stream()
                .min(Comparator.comparingLong(ChannelInfo::getRequestsPending))
                .orElseThrow();
        }
        
        private ChannelInfo selectWeightedRandom(Collection<ChannelInfo> channels) {
            // Calculate total weight
            int totalWeight = channels.stream()
                .mapToInt(ChannelInfo::getScore)
                .sum();
            
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 39.6K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/classrealm/DefaultClassRealmManager.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    import java.util.Random;
    import java.util.Set;
    import java.util.TreeMap;
    import java.util.stream.Collectors;
    
    import org.apache.maven.artifact.ArtifactUtils;
    import org.apache.maven.classrealm.ClassRealmRequest.RealmType;
    import org.apache.maven.extension.internal.CoreExports;
    import org.apache.maven.internal.CoreRealm;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  9. docs/logging/README.md

        "Content-Length": "401",
        "Content-Type": "application/octet-stream",
        "User-Agent": "MinIO (linux; amd64) minio-go/v7.0.70 mc/RELEASE.2024-04-30T17-44-48Z",
        "X-Amz-Content-Sha256": "STREAMING-AWS4-HMAC-SHA256-PAYLOAD",
        "X-Amz-Date": "20240509T073810Z",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java

         */
        @PluginFactory
        public static ErrorToWarnRewritePolicy createPolicy(@PluginAttribute("loggers") final String loggerNamePrefix) {
            final String[] loggerNames = loggerNamePrefix != null
                    ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n])
                    : new String[0];
            return new ErrorToWarnRewritePolicy(loggerNames);
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top