- Sort Score
- Num 10 results
- Language All
Results 441 - 450 of 762 for chunks (0.05 seconds)
-
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 */ @GwtIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 5.7K bytes - Click Count (0) -
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) -
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) -
src/main/java/org/codelibs/fess/util/PrunedTag.java
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) -
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) -
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) -
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) -
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) -
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) -
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)