- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 796 for Stream$ (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)