- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 240 for notificationTo (0.12 seconds)
-
android/guava/src/com/google/common/cache/CacheBuilder.java
* <li>keys automatically wrapped in {@linkplain WeakReference weak} references * <li>values automatically wrapped in {@linkplain WeakReference weak} or {@linkplain * SoftReference soft} references * <li>notification of evicted (or otherwise removed) entries * <li>accumulation of cache access statistics * </ul> * * <p>These features are all optional; caches can be created using all or none of them. By default,
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 52K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/chat/ChatClient.java
* @param userMessage the user's message * @param userId the user ID (can be null for anonymous users) * @param callback the callback to receive phase notifications and streaming chunks * @return the chat result with session info, sources, and HTML content */ public ChatResult streamChatEnhanced(final String sessionId, final String userMessage, final String userId,
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 56.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStarted(); } @Override protected void doStop() { notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private final long delay; NoOpDelayedService(long delay) { this.delay = delay; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
docs/bucket/replication/README.md

Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStarted(); } @Override protected void doStop() { notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private final long delay; NoOpDelayedService(long delay) { this.delay = delay; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
/** SMB2 query info command */ protected static final short SMB2_QUERY_INFO = 0x0010; /** SMB2 set info command */ protected static final short SMB2_SET_INFO = 0x0011; /** SMB2 opportunistic lock break notification */ protected static final short SMB2_OPLOCK_BREAK = 0x0012; /** * Flag indicating the message is a response from server to client. */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 24K bytes - Click Count (0) -
src/main/java/jcifs/Configuration.java
*/ long getDirectoryCacheTimeout(); /** * Property {@code jcifs.smb.client.directoryNotificationsEnabled} (boolean, default true) * * @return whether directory change notifications are enabled */ boolean isDirectoryNotificationsEnabled(); /** * Property {@code jcifs.smb.client.maxDirectoryCacheEntries} (int, default 1000) *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 25.4K bytes - Click Count (0) -
cmd/iam.go
// memberships cache. If the specified group does not exist in // storage, it is removed from in-memory maps as well - this // simplifies the implementation for group removal. This is called // only via IAM notifications. func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error { if !sys.Initialized() { return errServerNotInitialized } return sys.store.GroupNotificationHandler(ctx, group)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
* * Multiple calls to this method may be made concurrently. */ @Throws(IOException::class) abstract fun onStream(stream: Http2Stream) /** * Notification that the connection's peer's settings may have changed to [settings]. * Implementations should take appropriate action to handle the updated settings. *Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 31.9K bytes - Click Count (0) -
cmd/common-main.go
consoleapi.TLSPort = globalMinioConsolePort consoleapi.Hostname = globalMinioConsoleHost } return server, nil } // Check for updates and print a notification message func checkUpdate(mode string) { updateURL := minioReleaseInfoURL if runtime.GOOS == globalWindowsOSName { updateURL = minioReleaseWindowsInfoURL } u, err := url.Parse(updateURL)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.5K bytes - Click Count (3)