- Sort Score
- Result 10 results
- Languages All
Results 521 - 530 of 729 for streams (0.81 sec)
-
src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java
import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicReference; import java.util.function.BiConsumer; import java.util.stream.Collectors; import org.codelibs.fess.app.service.WebConfigService; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.opensearch.client.SearchEngineClient;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 19 23:49:30 UTC 2025 - 29.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/systeminfo/AdminSysteminfoAction.java
*/ public static List<Map<String, String>> getFessPropItems(final FessConfig fessConfig) { final List<Map<String, String>> itemList = new ArrayList<>(); ComponentUtil.getSystemProperties().entrySet().stream().forEach(e -> { final String k = e.getKey().toString(); final String value; if (isMaskedValue(k)) { value = MASKED_VALUE; } else {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/mime.map
application/mac-binhex40 hqx # Macintosh binhexed archives application/mspowerpoint ppt # Microsoft Powerpoint application/msword doc # Microsoft Word application/octet-stream bin exe ani # Binary File application/oda oda application/pagemaker pm5 pt5 pm # PageMaker application/pdf pdf # Adobe Acrobat
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 5.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableSortedMapTest.java
import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.SortedMap; import java.util.TreeMap; import java.util.function.BiPredicate; import java.util.stream.Collector; import java.util.stream.Stream; import junit.framework.Test; import junit.framework.TestCase; import junit.framework.TestSuite; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 27.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EmptyContiguousSet.java
@J2ktIncompatible @Override Object writeReplace() { return new SerializedForm<>(domain); } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use SerializedForm"); } @GwtIncompatible // NavigableSet @Override ImmutableSortedSet<C> createDescendingSet() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Set; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.CoreLibConstants; import org.codelibs.core.beans.util.BeanUtil;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/BridgeInterceptor.kt
requestBuilder.header("Connection", "Keep-Alive") } // If we add an "Accept-Encoding: gzip" header field we're responsible for also decompressing // the transfer stream. var transparentGzip = false if (userRequest.header("Accept-Encoding") == null && userRequest.header("Range") == null) { transparentGzip = true requestBuilder.header("Accept-Encoding", "gzip") }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/test-utils_test.go
signature = hex.EncodeToString(sumHMAC(signingKey, []byte(stringToSign))) stream = append(stream, []byte(fmt.Sprintf("%x", n)+";chunk-signature="+signature+"\r\n")...) stream = append(stream, buffer[:n]...) stream = append(stream, []byte("\r\n")...) if n <= 0 { break } } req.Body = io.NopCloser(bytes.NewReader(stream)) return req, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileOutputStreamTest.java
SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC, SmbConstants.FILE_WRITE_DATA, SmbConstants.DEFAULT_SHARING); // Close the stream outputStream.close(); // When & Then - after close, tmp is null so write(int) will throw NullPointerException // This is the actual behavior of the implementation
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt
package okhttp3 import okio.IOException import okio.Timeout /** * A call is a request that has been prepared for execution. A call can be canceled. As this object * represents a single request/response pair (stream), it cannot be executed twice. */ interface Call : Cloneable { /** Returns the original request that initiated this call. */ fun request(): Request /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.6K bytes - Viewed (0)