Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 850 for Streams (0.08 sec)

  1. guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java

      }
    
      /** In-memory stream-based implementation of Hasher. */
      private final class BufferingHasher extends AbstractHasher {
        final ExposedByteArrayOutputStream stream;
    
        BufferingHasher(int expectedInputSize) {
          this.stream = new ExposedByteArrayOutputStream(expectedInputSize);
        }
    
        @Override
        public Hasher putByte(byte b) {
          stream.write(b);
          return this;
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultArtifactManager.java

            }
        }
    
        /**
         * Retrieve a stream of the project's artifacts.
         * Do not include the POM artifact as the file can't be set anyway.
         */
        private Stream<org.apache.maven.artifact.Artifact> getProjectArtifacts(MavenProject project) {
            return Stream.concat(Stream.of(project.getArtifact()), project.getAttachedArtifacts().stream());
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. 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: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/fileconfig/ApiAdminFileconfigAction.java

            body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                    .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n")));
            body.virtualHosts = stream(entity.getVirtualHosts())
                    .get(stream -> stream.filter(StringUtil::isNotBlank).distinct().map(String::trim).collect(Collectors.joining("\n")));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlExtractor.java

            try {
                final ExtractData extractData = new ExtractData(
                        StreamUtil.stream(getStringsByXPath(document, contentXpath)).get(stream -> stream.collect(Collectors.joining(" "))));
                metadataXpathMap.entrySet().stream().forEach(e -> {
                    extractData.putValues(e.getKey(), getStringsByXPath(document, e.getValue()));
                });
                return extractData;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/webconfig/ApiAdminWebconfigAction.java

            body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                    .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n")));
            body.virtualHosts = stream(entity.getVirtualHosts())
                    .get(stream -> stream.filter(StringUtil::isNotBlank).distinct().map(String::trim).collect(Collectors.joining("\n")));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/taglib/FessFunctions.java

            } else if (input instanceof List) {
                values = ((List<?>) input).stream().filter(Objects::nonNull).map(Object::toString).toArray(n -> new String[n]);
            } else if (input instanceof String) {
                return input.toString();
            }
            if (values != null) {
                return stream(values).get(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).collect(Collectors.joining(" ")));
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Aug 24 01:40:03 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  9. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Aug 24 01:40:03 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/HashMultiset.java

      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultiset(this, stream);
      }
    
      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int distinctElements = Serialization.readCount(stream);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top