- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 319 for straum (0.17 sec)
-
android/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
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
return designJspFileNameMap.entrySet().stream().map(e -> new Pair<>(e.getKey(), e.getValue())).toArray(n -> new Pair[n]); } public List<Path> refreshDesignJspFiles() { final List<Path> fileList = new ArrayList<>(); stream(ComponentUtil.getVirtualHostHelper().getVirtualHostPaths()) .of(stream -> stream.filter(s -> s != null && !"/".equals(s)).forEach(key -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java
*/ package org.codelibs.fess.helper; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.regex.Pattern; import java.util.stream.Collectors; import javax.annotation.PostConstruct;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 11.7K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/util/GsaConfigParser.java
final List<String> urlList = split(startUrls.toString(), "\n") .get(stream -> stream.map(String::trim).filter(StringUtil::isNotBlank).collect(Collectors.toList())); final String webUrls = urlList.stream().filter(s -> Arrays.stream(webProtocols).anyMatch(p -> s.startsWith(p))) .collect(Collectors.joining("\n"));
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 14.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/saml/SamlAuthenticator.java
if (!errors.isEmpty()) { logger.warn("{}", errors.stream().collect(Collectors.joining(", "))); if (auth.isDebugActive() && StringUtil.isNotBlank(auth.getLastErrorReason())) { logger.warn("Authentication Failure: {} - Reason: {}", errors.stream().collect(Collectors.joining(", ")), auth.getLastErrorReason());
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 15.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java
stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p))); putResultDataBody(dataMap, fessConfig.getIndexFieldRole(), roleTypeList); // virtualHosts putResultDataBody(dataMap, fessConfig.getIndexFieldVirtualHost(), stream(crawlingConfig.getVirtualHosts()).get(stream -> stream.filter(StringUtil::isNotBlank).collect(Collectors.toList())));
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 23.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSource.java
* returned stream is closed. * <li><b>Convenience methods:</b> These are implementations of common operations that are * typically implemented by opening a stream using one of the methods in the first category, * doing something and finally closing the stream that was opened. * </ul> * * <p><b>Note:</b> In general, {@code ByteSource} is intended to be used for "file-like" sources
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 26.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
writeBytesTotal >= writeBytesMaximum || stream.writeBytesTotal >= stream.writeBytesMaximum if (stream.isOpen) { streams[streamId] = stream } } if (associatedStreamId == 0) { writer.headers(outFinished, streamId, requestHeaders) } else { require(!client) { "client streams shouldn't have associated stream IDs" } // HTTP/2 has a PUSH_PROMISE frame.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/TableCollectorsTest.java
import com.google.common.collect.Table.Cell; import com.google.common.testing.CollectorTester; import java.util.function.BiPredicate; import java.util.function.BinaryOperator; import java.util.stream.Collector; import java.util.stream.Stream; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** Unit tests for {@link TableCollectors}. */ @GwtCompatible(emulated = true)
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Mar 05 16:03:18 GMT 2024 - 11.7K 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!", ) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0)