- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 1,237 for afterFn (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bootstrap-peer-server_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgServerSystemConfig(b *testing.B) { v := ServerSystemConfig{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.4K bytes - Click Count (0) -
cmd/bucket-metadata_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketMetadata(b *testing.B) { v := BucketMetadata{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Suppliers.java
+ ")"; } } /** * Returns a supplier that caches the instance supplied by the delegate and removes the cached * value after the specified time has passed. Subsequent calls to {@code get()} return the cached * value if the expiration time has not passed. After the expiration time, a new value is * retrieved, cached, and returned. See: <a * href="http://en.wikipedia.org/wiki/Memoization">memoization</a> *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 31 21:24:28 GMT 2026 - 16.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* #collectValueFromNonCancelledFuture}. As this is called after the subclass is constructed, * we're guaranteed to have properly initialized the subclass. */ final void init() { /* * requireNonNull is safe because this is called from the constructor after `futures` is set but * before releaseResources could be called (because we have not yet set up any of the listeners
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 16K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java
long allocatedBeforeCleanup = bufferManager.getTotalAllocated(); // Cleanup should not throw exception assertDoesNotThrow(() -> bufferManager.cleanup()); // After cleanup, all regions should be released (but the count may not match exactly // if some regions were pooled rather than immediately released)Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.1K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* Cache} interfaces. The {@code asMap} view (and its collection views) have <i>weakly consistent * iterators</i>. This means that they are safe for concurrent use, but if other threads modify the * cache after the iterator is created, it is undefined which of these changes, if any, are * reflected in that iterator. These iterators never throw {@link ConcurrentModificationException}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 52K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt
* * With regular HTTP calls the request always completes sending before the response may begin * receiving. With duplex the request and response may be interleaved! That is, request body bytes * may be sent after response headers or body bytes have been received. * * Though any call may be initiated as a duplex call, only web servers that are specially
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:29 GMT 2025 - 9.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* annotation type, rather than an interface */ <T> T newProxy(T target, Class<T> interfaceType, long timeoutDuration, TimeUnit timeoutUnit); /** * Invokes a specified Callable, timing out after the specified time limit. If the target method * call finishes before the limit is reached, the return value or a wrapped exception is * propagated. If, on the other hand, the time limit is reached, we attempt to abort the call to
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 8.2K bytes - Click Count (0) -
src/test/java/jcifs/smb/JAASAuthenticatorTest.java
// Refresh should clear the cache auth.refresh(); Subject afterRefresh = auth.getSubject(); // After refresh, may succeed or fail depending on JAAS configuration // Just verify that refresh doesn't break the authenticator assertNotNull(auth, "Authenticator should remain usable after refresh"); } @Test @DisplayName("handle: sets NameCallback and PasswordCallback on happy path")Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 9.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/pager/CrawlingInfoPager.java
this.existPrePage = existPrePage; } /** * Checks if a next page exists after the current page. * * @return true if a next page exists, false otherwise */ public boolean isExistNextPage() { return existNextPage; } /** * Sets whether a next page exists after the current page. * * @param existNextPage true if a next page exists, false otherwiseCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 6.9K bytes - Click Count (0)