Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Stalla (0.16 sec)

  1. mockwebserver-deprecated/api/mockwebserver.api

    	public static final field SHUTDOWN_OUTPUT_AT_END Lokhttp3/mockwebserver/SocketPolicy;
    	public static final field SHUTDOWN_SERVER_AFTER_RESPONSE Lokhttp3/mockwebserver/SocketPolicy;
    	public static final field STALL_SOCKET_AT_START Lokhttp3/mockwebserver/SocketPolicy;
    	public static final field UPGRADE_TO_SSL_AT_END Lokhttp3/mockwebserver/SocketPolicy;
    	public static fun getEntries ()Lkotlin/enums/EnumEntries;
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jul 22 12:28:51 GMT 2023
    - 10.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DuplexTest.kt

        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
        }
      }
    
      /** Same as the previous test, but the server stalls sending the response body.  */
      @Test
      fun bodyReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() {
        enableProtocol(Protocol.HTTP_2)
        server.enqueue(
          MockResponse.Builder()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 23.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

      public static RateLimiter create(double permitsPerSecond) {
        /*
         * The default RateLimiter configuration can save the unused permits of up to one second. This
         * is to avoid unnecessary stalls in situations like this: A RateLimiter of 1qps, and 4 threads,
         * all calling acquire() at these moments:
         *
         * T0 at 0 seconds
         * T1 at 1.05 seconds
         * T2 at 2 seconds
         * T3 at 3 seconds
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      fun sleep(durationNanos: Long) {
        taskRunner.lock.withLock {
          val sleepUntil = nanoTime + durationNanos
          yieldUntil { nanoTime >= sleepUntil }
        }
      }
    
      /**
       * Artificially stall until manually resumed by the test thread with [runTasks]. Use this to
       * simulate races in tasks that doesn't have a deterministic sequence.
       */
      fun yield() {
        taskRunner.assertThreadDoesntHoldLock()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  5. docs/it/docs/index.md

    FastAPI è un web framework moderno e veloce (a prestazioni elevate) che serve a creare API con Python 3.6+ basato sulle annotazioni di tipo di Python.
    
    Le sue caratteristiche principali sono:
    
    * **Velocità**: Prestazioni molto elevate, alla pari di **NodeJS** e **Go** (grazie a Starlette e Pydantic). [Uno dei framework Python più veloci in circolazione](#performance).
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 23:58:47 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_4x.md

     *  Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this
        happened enough then eventually the connection would stall.
    
     *  Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we
        could use new flow control capacity before acknowledging it, causing strict HTTP/2 servers to
        fail the call.
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

       */
      @Test
      fun unacknowledgedPingFailsConnection() {
        assumeNotWindows()
        client =
          client.newBuilder()
            .pingInterval(Duration.ofMillis(500))
            .build()
    
        // Stall in onOpen to prevent pongs from being sent.
        val latch = CountDownLatch(1)
        webServer.enqueue(
          MockResponse.Builder()
            .webSocketUpgrade(
              object : WebSocketListener() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 35.2K bytes
    - Viewed (1)
Back to top