Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 762 for chunks (0.28 seconds)

  1. android/guava-testlib/src/com/google/common/collect/testing/SafeTreeSet.java

    import java.util.Iterator;
    import java.util.NavigableSet;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A wrapper around {@code TreeSet} that aggressively checks to see if elements are mutually
     * comparable. This implementation passes the navigable set test suites.
     *
     * @author Louis Wasserman
     */
    @GwtIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/EvictingQueue.java

         *
         * However, the checker *we* use has this special knowledge about `Collection.toArray()` anyway,
         * so in our implementation code, we can rely on that. That's why the expression below
         * type-checks.
         */
        return super.toArray();
      }
    
      @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0L;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/nego/NegotiateContextResponseTest.java

                assertEquals(0, context.getSalt().length);
            }
    
            @ParameterizedTest
            @ValueSource(ints = { 0, 1, 3, 5, 10 })
            @DisplayName("Should calculate size correctly for different hash algo counts")
            void testSizeCalculation(int hashAlgoCount) {
                // Arrange
                int[] hashAlgos = new int[hashAlgoCount];
                byte[] salt = new byte[16];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/util/PrunedTag.java

         *
         * @param tag the HTML tag name to match (e.g., "div", "span", "p")
         */
        public PrunedTag(final String tag) {
            this.tag = tag;
        }
    
        /**
         * Checks if this pruned tag configuration matches the given DOM node.
         * The matching is based on tag name, and optionally ID, CSS class, or custom attributes.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Nov 24 04:23:08 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java

                } catch (IOException e) {
                    log.warn("Failed to establish RDMA connection: {}", e.getMessage());
                    throw e;
                }
            }
        }
    
        /**
         * Checks if RDMA connection is available.
         *
         * @return true if RDMA connection is active
         */
        public boolean isRdmaConnected() {
            synchronized (connectionLock) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/SmbRandomAccessFileTest.java

            raf.writeShort(1);
            raf.writeChar('A');
            raf.writeInt(1);
            raf.writeLong(1L);
            raf.writeFloat(1.0f);
            raf.writeDouble(1.0);
    
            // Verify length counts - using times() to check exact counts
            verify(raf, times(2)).write(any(byte[].class), anyInt(), eq(2)); // short and char
            verify(raf, times(2)).write(any(byte[].class), anyInt(), eq(4)); // int and float
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  7. docs/zh/docs/advanced/stream-data.md

    在这个特定示例中这并不那么重要,因为它是一个内存中的假文件(使用 `io.BytesIO`),但对于真实文件,确保在完成相关工作后关闭文件是很重要的。
    
    ### 文件与异步 { #files-and-async }
    
    大多数情况下,类文件对象默认与 async 和 await 不兼容。
    
    例如,它们没有 `await file.read()`,也不支持 `async for chunk in file`。
    
    而且很多情况下,读取它们是一个阻塞操作(可能会阻塞事件循环),因为数据来自磁盘或网络。
    
    /// info | 信息
    
    上面的示例其实是个例外,因为 `io.BytesIO` 对象已经在内存中,所以读取它不会阻塞。
    
    但在许多情况下,读取文件或类文件对象会发生阻塞。
    
    ///
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:29:48 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

          if (!compareAndSet(currentThread, DONE)) {
            waitForInterrupt(currentThread);
          }
          if (run) {
            if (error == null) {
              // The cast is safe because of the `run` and `error` checks.
              afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result));
            } else {
              afterRanInterruptiblyFailure(error);
            }
          }
        }
      }
    
      @SuppressWarnings({
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * nullness annotations in particular will outweigh the costs. (And it's worth noting that we have
     * released multiple ListenableFuture.class files that are not byte-for-byte compatible even from
     * the beginning, thanks to using different `-source -target` values for compiling our `-jre` and
     * `-android` "flavors.")
     *
     * (We could consider releasing a listenablefuture:1.0.1 someday. But we would want to look into how
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
      public ThreadFactoryBuilder setPriority(int priority) {
        // Thread#setPriority() already checks for validity. These error messages
        // are nicer though and will fail-fast.
        checkArgument(
            priority >= Thread.MIN_PRIORITY,
            "Thread priority (%s) must be >= %s",
            priority,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 9.2K bytes
    - Click Count (0)
Back to Top