Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 849 for upstream (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  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. src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java

            verifyTokenKeep(() -> downloadpage(form.dictId));
            return stemmerOverrideService.getStemmerOverrideFile(form.dictId)
                    .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> {
                        file.writeOut(out);
                    })).orElseGet(() -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  6. 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)
  7. compat/maven-model-builder/src/test/java/org/apache/maven/model/building/FileToRawModelMergerTest.java

     */
    package org.apache.maven.model.building;
    
    import java.lang.reflect.Method;
    import java.lang.reflect.ParameterizedType;
    import java.lang.reflect.Type;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.model.v4.MavenMerger;
    import org.junit.jupiter.api.Test;
    
    import static org.hamcrest.MatcherAssert.assertThat;
    import static org.hamcrest.Matchers.hasItems;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. compat/maven-settings/src/main/java/org/apache/maven/settings/io/xpp3/SettingsXpp3Writer.java

            }
        }
    
        /**
         * Method write.
         *
         * @param stream a stream object.
         * @param settings a settings object.
         * @throws IOException java.io.IOException if any.
         */
        public void write(OutputStream stream, Settings settings) throws IOException {
            try {
                delegate.write(stream, settings.getDelegate());
            } catch (XMLStreamException e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  9. cmd/object-api-utils_test.go

    			metadata: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86", "x-amz-storage-class": "STANDARD"},
    			want:     map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86"},
    		},
    		{
    			name:     "2",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java

            verifyTokenKeep(() -> downloadpage(form.dictId));
            return kuromojiService.getKuromojiFile(form.dictId)
                    .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> {
                        file.writeOut(out);
                    })).orElseGet(() -> {
                        throwValidationError(messages -> messages.addErrorsFailedToDownloadKuromojiFile(GLOBAL),
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 18.8K bytes
    - Viewed (0)
Back to top