Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 194 for listeners (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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 ignored
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. 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 ignored
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top