- Sort Score
- Result 10 results
- Languages All
Results 491 - 500 of 1,050 for Spread (0.03 sec)
-
android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java
ByteStreams.skipFully(multi, 20); assertEquals(20, multi.read()); } public void testReadSingle_noStackOverflow() throws IOException { // https://github.com/google/guava/issues/2996 // no data, just testing that there's no StackOverflowException assertEquals(-1, tenMillionEmptySources().read()); } public void testReadArray_noStackOverflow() throws IOException {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:44:53 UTC 2025 - 4.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java
* <p> * The class uses a static {@code idCount} to generate unique IDs for each access result. * The {@code idCountLock} object is used to synchronize access to the {@code idCount} variable, * ensuring that IDs are generated in a thread-safe manner. * </p> * * <p> * The class also provides methods to get the count of access results for a given session, * to delete all access results for a given session, and to delete all access results. * </p>Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 6.9K bytes - Viewed (0) -
README.md
- **Authentication**: NTLM, Kerberos, SPNEGO unified subsystem - **SLF4J Logging**: Comprehensive logging throughout the codebase - **Resource Management**: AutoCloseable patterns for file handles and connections - **Thread Safety**: Components support concurrent access - **DFS Support**: Distributed File System resolution - **Streaming Operations**: Efficient directory listings and file operations - **Buffer Caching**: Optimized buffer management
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 09:24:52 UTC 2025 - 6.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/PatternFilenameFilter.java
import java.io.File; import java.io.FilenameFilter; import java.util.regex.Pattern; import java.util.regex.PatternSyntaxException; /** * File name filter that only accepts files matching a regular expression. This class is thread-safe * and immutable. * * @author Apple Chow * @since 1.0 */ @J2ktIncompatible @GwtIncompatible public final class PatternFilenameFilter implements FilenameFilter { private final Pattern pattern;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2.7K bytes - Viewed (1) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingSortedMultiset.java
* method. * * <p>The {@code standard} methods and any collection views they return are not guaranteed to be * thread-safe, even when all of the methods that they depend on are thread-safe. * * @author Louis Wasserman */ public abstract class ForwardingSortedMultiset<E extends @Nullable Object> extends ForwardingMultiset<E> implements SortedMultiset<E> {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeMultiset.java
/** Constructor for the header node. */ AvlNode() { this.elem = null; this.elemCount = 1; } // For discussion of pred() and succ(), see the comment on the pred and succ fields. private AvlNode<E> pred() { return requireNonNull(pred); } private AvlNode<E> succ() { return requireNonNull(succ); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 34.3K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/RtmSession.java
if (webSocket != null) throw new IllegalStateException(); RtmStartResponse rtmStartResponse = slackApi.rtmStart(accessToken); webSocket = slackApi.rtm(rtmStartResponse.url, this); } // TODO(jwilson): can I read the response body? Do I have to? // the body from slack is a 0-byte-buffer @Override public synchronized void onOpen(WebSocket webSocket, Response response) { System.out.println("onOpen: " + response); }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 19 20:16:58 UTC 2016 - 2.4K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/Trans2SetFileInformationResponseTest.java
/** * Test for the readSetupWireFormat method. * It should always return 0. */ @Test void testReadSetupWireFormat() { byte[] buffer = new byte[10]; // The method should not read anything and return 0 assertEquals(0, response.readSetupWireFormat(buffer, 0, 10), "readSetupWireFormat should return 0."); } /** * Test for the readParametersWireFormat method.Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/IoTestCase.java
InputStream in = url.openStream(); try { OutputStream out = new FileOutputStream(file); try { byte[] buf = new byte[4096]; for (int read = in.read(buf); read != -1; read = in.read(buf)) { out.write(buf, 0, read); } } finally { out.close(); } } finally { in.close(); } } @CanIgnoreReturnValue
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/TextExtractorEnhancedTest.java
// Create a stream that will cause an error during reading final InputStream errorStream = new InputStream() { @Override public int read() throws IOException { throw new IOException("Simulated read error"); } }; final String customEncoding = "ISO-8859-1"; textExtractor.setEncoding(customEncoding); try {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 8.9K bytes - Viewed (0)