Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 1,050 for Spread (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top