Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 796 for Stream$ (0.05 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse download(final String id) {
            if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) {
                if ("system.properties".equals(id)) {
                    return asStream(id).contentTypeOctetStream().stream(out -> {
                        try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                final Stream<QueryLog> stream = Stream.of(queryLogs);
                if (parallel) {
                    stream.parallel();
                }
                final SuggestItem[] array = stream
                        .flatMap(queryLog -> contentsParser
                                .parseQueryLog(queryLog, supportedFields, tagFieldNames, roleFieldName, readingConverter, normalizer).stream())
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

          )
          request.isChunked -> newChunkedSink() // Stream a request body of unknown length.
          contentLength != -1L -> newKnownLengthSink() // Stream a request body of a known length.
          else -> // Stream a request body of a known length.
            throw IllegalStateException(
              "Cannot stream a request body without chunked encoding or a known content length!",
            )
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java

            });
    
            final EditBody body = createEditBody(entity);
            final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper();
            body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                    .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n")));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MoreCollectors.java

      /**
       * A collector that converts a stream of zero or one elements to an {@code Optional}.
       *
       * @throws IllegalArgumentException if the stream consists of two or more elements.
       * @throws NullPointerException if any element in the stream is {@code null}.
       * @return {@code Optional.of(onlyElement)} if the stream has exactly one element (must not be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/fileconfig/AdminFileconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.fileconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/webconfig/AdminWebconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.webconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionStreamTester.java

      /*
       * We're not really testing the implementation of Stream, only that we're getting a Stream
       * that corresponds to the expected elements.
       */
    
      @CollectionFeature.Require(absent = KNOWN_ORDER)
      public void testStreamToArrayUnknownOrder() {
        Helpers.assertEqualIgnoringOrder(getSampleElements(), asList(collection.stream().toArray()));
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:51:04 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/ByteStreams.java

      /**
       * Copies all bytes from the input stream to the output stream. Does not close or flush either
       * stream.
       *
       * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the
       * equivalent {@link InputStream#transferTo} method instead.
       *
       * @param from the input stream to read from
       * @param to the output stream to write to
       * @return the number of bytes copied
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

                response.off += n;
            } while( len > 0 && n == r );
    
            return (int)(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
     * on the server.
     */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.9K bytes
    - Viewed (0)
Back to top