Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,030 for stream (0.04 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultPluginDependenciesResolver.java

                List<Exception> exceptions = Stream.concat(
                                e.getResult().getCollectExceptions().stream(),
                                e.getResult().getArtifactResults().stream()
                                        .filter(r -> !r.isResolved())
                                        .flatMap(r -> r.getExceptions().stream()))
                        .collect(Collectors.toList());
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Sep 29 15:32:43 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  2. src/test/java/jcifs/netbios/NbtExceptionTest.java

    package jcifs.netbios;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.junit.jupiter.api.Assertions.fail;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.Arguments;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb1/com/SmbComNTCreateAndXTest.java

        }
    
        @Nested
        @DisplayName("Constructor createDisposition calculation")
        class CreateDispositionTests {
            static java.util.stream.Stream<Arguments> flagsProvider() {
                return java.util.stream.Stream.of(
                        Arguments.of(SmbConstants.O_TRUNC | SmbConstants.O_CREAT, SmbComNTCreateAndX.FILE_OVERWRITE_IF),
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/main/java/jcifs/smb/SmbFileInputStream.java

                    }
                }
    
                return (int) (this.fp - start);
            }
        }
    
        /**
         * This stream class is unbuffered. Therefore this method will always
         * return 0 for streams connected to regular files. However, a
         * stream created from a Named Pipe this method will query the server using a
         * "peek named pipe" operation and return the number of available bytes
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.6K bytes
    - Viewed (0)
Back to top