Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 212 for listenCh (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
          return super.cancel(mayInterruptIfRunning);
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/alerts.md

        target_match:
          severity: 'warning'
        equal: ['alertname', 'dev', 'instance']
    ```
    
    This sample configuration uses a `webhook` at http://127.0.0.1:8010/webhook to post the alerts.
    Start the AlertManager and it listens on port `9093` by default. Make sure your webhook is up and listening for the alerts.
    
    ## Configure Prometheus to use AlertManager
    
    Add below section to your `prometheus.yml`
    ```yaml
    alerting:
      alertmanagers:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 23 15:13:23 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          return sync.wasInterrupted();
        }
    
        /**
         * {@inheritDoc}
         *
         * @since 10.0
         */
        @Override
        public void addListener(Runnable listener, Executor exec) {
          executionList.add(listener, exec);
        }
    
        /**
         * Subclasses should invoke this method to set the result of the computation to {@code value}.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  8. docs/de/docs/tutorial/extra-models.md

    Um das zu tun, verwenden Sie Pythons Standard-Typhinweis <a href="https://docs.python.org/3/library/typing.html#typing.Union" class="external-link" target="_blank">`typing.Union`</a>:
    
    /// note | Hinweis
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

       * first DNS result for the first time.
       */
      @Test
      fun prefersExistingCompatible() {
        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
        val connectCount = AtomicInteger()
        val listener: EventListener =
          object : EventListener() {
            override fun connectStart(
              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  10. 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)
Back to top