Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,102 for Stream (1.37 sec)

  1. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/InvokerRequest.java

        /**
         * Returns the input stream for the Maven execution, if running in embedded mode.
         *
         * @return an {@link Optional} containing the input stream, or empty if not applicable
         */
        @Nonnull
        default Optional<InputStream> stdIn() {
            return Optional.ofNullable(parserRequest().stdIn());
        }
    
        /**
         * Returns the output stream for the Maven execution, if running in embedded mode.
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jun 11 13:14:09 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/primitives/ImmutableIntArray.java

      }
    
      /**
       * Returns an immutable array containing all the values from {@code stream}, in order.
       *
       * @since 22.0 (but only since 33.4.0 in the Android flavor)
       */
      public static ImmutableIntArray copyOf(IntStream stream) {
        // Note this uses very different growth behavior from copyOf(Iterable) and the builder.
        int[] array = stream.toArray();
        return (array.length == 0) ? EMPTY : new ImmutableIntArray(array);
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 14:49:24 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/EXTRACTOR_TESTS_README.md

    - ✅ Failed extraction includes descriptive error messages
    - ✅ Null input stream validation
    - ✅ Error messages include file type context
    
    ---
    
    ### 2. FilenameExtractorEnhancedTest.java
    **Purpose**: Test FilenameExtractor edge cases and new documentation.
    
    **Key Test Areas**:
    - Parameter handling (null, empty, missing)
    - Special character handling
    - Input stream validation (not consumption)
    - Edge cases (long filenames, paths, whitespace)
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Wed Nov 19 08:55:01 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/EnumBiMap.java

       */
      @GwtIncompatible // java.io.ObjectOutputStream
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(keyTypeOrObjectUnderJ2cl);
        stream.writeObject(valueTypeOrObjectUnderJ2cl);
        Serialization.writeMap(this, stream);
      }
    
      @SuppressWarnings("unchecked") // reading fields populated by writeObject
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 15:50:50 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/NotificationHelper.java

            if (StringUtil.isBlank(slackWebhookUrls)) {
                return;
            }
            final String body = toSlackMessage(discloser);
            StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> {
                try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) {
                    if (response.getHttpStatusCode() == 200) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/GroupService.java

            });
    
            userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> {
                entity.setGroups(
                        stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
                userBhv.insertOrUpdate(entity);
            });
    
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/search/SearchAction.java

                }
            }
            form.fields.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> {
                final String key = LaFunctions.u(e.getKey());
                stream(e.getValue()).of(stream -> stream.filter(StringUtil::isNotBlank)
                        .forEach(s -> pagingQueryList.add("fields." + key + "=" + LaFunctions.u(s))));
            });
            form.as.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/service/AccessTokenService.java

                    }
                    stream(accessToken.getPermissions()).of(stream -> stream.forEach(permissionSet::add));
                    final String name = accessToken.getParameterName();
                    stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add));
                    return OptionalEntity.of(permissionSet);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          is CloseStream -> {
            if (stream != null) {
              stream.close(ErrorCode.fromHttp2(effect.http2ErrorCode)!!, null)
            } else {
              socket.close()
            }
          }
    
          ShutdownConnection -> {
            if (stream != null) {
              stream.connection.shutdown(ErrorCode.NO_ERROR)
            } else {
              socket.close()
            }
          }
    
          is CloseSocket -> {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/io/WriterUtil.java

         */
        protected WriterUtil() {
        }
    
        /**
         * Creates a {@link Writer} to output to a stream with the specified encoding.
         *
         * @param os the stream (must not be {@literal null})
         * @param encoding the encoding (must not be {@literal null} or empty)
         * @return a {@link Writer} to output to the stream
         */
        public static Writer create(final OutputStream os, final String encoding) {
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 3K bytes
    - Viewed (0)
Back to top