- Sort Score
- Num 10 results
- Language All
Results 431 - 440 of 871 for Spread (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/collect/Multimaps.java
for (Map.Entry<? extends V, ? extends K> entry : source.entries()) { dest.put(entry.getValue(), entry.getKey()); } return dest; } /** * Returns a synchronized (thread-safe) multimap backed by the specified multimap. In order to * guarantee serial access, it is critical that <b>all</b> access to the backing multimap is * accomplished through the returned multimap. *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 86.5K bytes - Click Count (0) -
cmd/erasure-object-conditional_test.go
if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-match is used with quorum failure, got: %v", err) } }) t.Run("if-match wrong etag with read quorum failure", func(t *testing.T) { // Test Case 3: if-match with wrong ETag // Even if the ETag doesn't match, we should still get read quorum error // because we can't read the object to check the condition. opts := ObjectOptions{Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 4.9K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
} } else { // In the case of a concurrent remove, we might observe a zero value, which means another // thread is about to remove (element, existingCounter) from the map. Rather than wait, // we can just do that work here. AtomicInteger newCounter = new AtomicInteger(occurrences);Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 08 22:42:14 GMT 2025 - 22.3K bytes - Click Count (0) -
compat/maven-settings/src/main/java/org/apache/maven/settings/io/xpp3/SettingsXpp3Reader.java
} public Settings read(Reader reader, boolean strict) throws IOException, XmlPullParserException { try { return new Settings(delegate.read(reader, strict, null)); } catch (XMLStreamException e) { throw new XmlPullParserException(e.getMessage(), null, e); } } public Settings read(Reader reader) throws IOException, XmlPullParserException {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 4K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java
*/ @Override public int read() throws IOException { return inputStream.read(); } /** * Reads up to len bytes of data from the input stream into an array of bytes. * * @param b the buffer into which the data is read * @param off the start offset in array b at which the data is written * @param len the maximum number of bytes to readCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Nov 22 13:28:22 GMT 2025 - 4.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
* cache size. The application needs to be aware of calling this function during the * initialization phase and preferably in a background worker thread. * * Note that if the application chooses to not call this method to initialize the cache. By * default, OkHttp will perform lazy initialization upon the first usage of the cache. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Oct 03 17:41:45 GMT 2025 - 26.8K bytes - Click Count (0) -
compat/maven-toolchain-builder/src/test/java/org/apache/maven/toolchain/merge/MavenToolchainMergerTest.java
InputStream isRecessive = MavenToolchainMergerTest.class.getResourceAsStream("toolchains-jdks.xml")) { PersistedToolchains dominant = read(isDominant); PersistedToolchains recessive = read(isRecessive); assertEquals(2, dominant.getToolchains().size()); merger.merge(dominant, recessive, TrackableBase.USER_LEVEL);
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
} body.awaitSuccess() } /** * Duplex calls that have follow-ups are weird. By the time we know there's a follow-up we've * already split off another thread to stream the request body. Because we permit at most one * exchange at a time we break the request stream out from under that writer. */ @Test fun duplexWithRedirect() { enableProtocol(Protocol.HTTP_2)Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/ConcurrentLifecycleStarter.java
logger.info(""); logger.info(String.format( "Using the %s implementation with a thread count of %d", executor.getClass().getSimpleName(), degreeOfConcurrency)); } ClassLoader oldContextClassLoader = Thread.currentThread().getContextClassLoader();
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 8.3K bytes - Click Count (0) -
src/test/java/jcifs/netbios/SessionServicePacketTest.java
} @Test @DisplayName("readn should handle multiple read calls") void testReadnMultipleCalls() throws IOException { when(mockInputStream.read(any(byte[].class), anyInt(), anyInt())).thenReturn(2) // First read returns 2 bytes .thenReturn(2) // Second read returns 2 bytes .thenReturn(1); // Third read returns 1 byte byte[] buffer = new byte[10];Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.5K bytes - Click Count (0)