- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 194 for listeners (0.11 sec)
-
src/test/java/org/codelibs/fess/job/CrawlJobTest.java
JobExecutor mockJobExecutor = new JobExecutor() { @Override public void addShutdownListener(ShutdownListener listener) { shutdownListeners.add(listener); } @Override public Object execute(String scriptType, String script) { return null; } };Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 25K bytes - Viewed (0) -
api/go1.9.txt
pkg net, type Resolver struct, StrictErrors bool pkg net/http, func ServeTLS(net.Listener, Handler, string, string) error pkg net/http, method (*Server) RegisterOnShutdown(func()) pkg net/http, method (*Server) ServeTLS(net.Listener, string, string) error pkg net/http/fcgi, func ProcessEnv(*http.Request) map[string]string
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Oct 04 20:20:20 UTC 2021 - 10.7K bytes - Viewed (0) -
docs/en/docs/fastapi-cli.md
## `fastapi run` { #fastapi-run } Executing `fastapi run` starts FastAPI in production mode by default.Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 4.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ResolutionListener.java
* under the License. */ package org.apache.maven.artifact.resolver; import org.apache.maven.artifact.Artifact; import org.apache.maven.artifact.versioning.VersionRange; /** * Listens to the resolution process and handles events. */ @Deprecated public interface ResolutionListener { String ROLE = ResolutionListener.class.getName(); int TEST_ARTIFACT = 1; int PROCESS_CHILDREN = 2;Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sun Mar 30 23:08:36 UTC 2025 - 2.8K bytes - Viewed (0) -
cmd/tier.go
if config == nil { return true } return len(config.ListTiers()) == 0 } // TierType returns the type of tier func (config *TierConfigMgr) TierType(name string) string { config.RLock() defer config.RUnlock() cfg, ok := config.Tiers[name] if !ok { return "internal" } return cfg.Type.String() } // ListTiers lists remote tiers configured in this deployment.Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
/** * Value for [B1_MASK_LENGTH] which indicates the next eight bytes are the unsigned * length. */ internal const val PAYLOAD_LONG = 127 /** Used when an unchecked exception was thrown in a listener. */ internal const val CLOSE_CLIENT_GOING_AWAY = 1001 /** Used when an empty close frame was received (i.e., without a status code). */ internal const val CLOSE_NO_STATUS_CODE = 1005 fun toggleMask(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
*/ public fun webSocketUpgrade(listener: WebSocketListener): Builder = apply { status = "HTTP/1.1 101 Switching Protocols" setHeader("Connection", "Upgrade") setHeader("Upgrade", "websocket") webSocketListener = listener } /**Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 17.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
private boolean hasShutdownListener = false; @Override public void addShutdownListener(ShutdownListener listener) { hasShutdownListener = true; super.addShutdownListener(listener); } @Override public Object execute(String scriptType, String script) { return null; }Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 31.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
throw EXCEPTION; } return outputFuture; } } public void testFutureGetThrowsFunctionException() throws Exception { inputFuture.set(EXCEPTION_DATA); listener.assertException(EXCEPTION); } public void testFutureGetThrowsCancellationIfInputCancelled() throws Exception { inputFuture.cancel(true); // argument is ignoredRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
throw EXCEPTION; } return outputFuture; } } public void testFutureGetThrowsFunctionException() throws Exception { inputFuture.set(EXCEPTION_DATA); listener.assertException(EXCEPTION); } public void testFutureGetThrowsCancellationIfInputCancelled() throws Exception { inputFuture.cancel(true); // argument is ignoredRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 6.3K bytes - Viewed (0)