Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Wings (0.02 sec)

  1. internal/s3select/sql/jsonpath_test.go

    		participle.CaseInsensitive("Keyword"),
    	)
    	cases := []struct {
    		str string
    		res []interface{}
    	}{
    		{"s.title", []interface{}{"Murder on the Orient Express", "The Robots of Dawn", "Pigs Have Wings"}},
    		{"s.authorInfo.yearRange", []interface{}{[]interface{}{1890.0, 1976.0}, []interface{}{1920.0, 1992.0}, []interface{}{1881.0, 1975.0}}},
    		{"s.authorInfo.name", []interface{}{"Agatha Christie", "Isaac Asimov", "P. G. Wodehouse"}},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         *
         * The default value of 0 disables client-initiated pings.
         */
        fun pingInterval(
          interval: Long,
          unit: TimeUnit,
        ) = apply {
          pingInterval = checkDuration("interval", interval, unit)
        }
    
        /**
         * Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      /** True if this web socket failed and the listener has been notified. */
      private var failed = false
    
      /** Total number of pings sent by this web socket. */
      private var sentPingCount = 0
    
      /** Total number of pings received by this web socket. */
      private var receivedPingCount = 0
    
      /** Total number of pongs received by this web socket. */
      private var receivedPongCount = 0
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        assertThat(server.receivedPongCount()).isEqualTo(0)
        closeWebSockets(webSocket, server)
      }
    
      /**
       * Configure the websocket to send pings every 500 ms. Artificially prevent the server from
       * responding to pings. The client should give up when attempting to send its 2nd ping, at about
       * 1000 ms.
       */
      @Test
      fun unacknowledgedPingFailsConnection() {
        assumeNotWindows()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      private val settingsListenerQueue = taskRunner.newQueue()
    
      /** User code to run in response to push promise events. */
      private val pushObserver: PushObserver = builder.pushObserver
    
      // Total number of pings send and received of the corresponding types. All guarded by this.
      private var intervalPingsSent = 0L
      private var intervalPongsReceived = 0L
      private var degradedPingsSent = 0L
      private var degradedPongsReceived = 0L
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        client.processNextFrame()
        taskFaker.runTasks()
        server.webSocket!!.pong("pong 3".encodeUtf8())
        client.processNextFrame()
    
        // After 500ms the client automatically pings and the server pongs back.
        taskFaker.advanceUntil(ns(500L))
        server.processNextFrame() // Ping.
        client.processNextFrame() // Pong.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  7. docs/en/docs/python-types.md

    At the same point, you try to trigger the autocomplete with `Ctrl+Space` and you see:
    
    <img src="/img/python-types/image02.png">
    
    With that, you can scroll, seeing the options, until you find the one that "rings a bell":
    
    <img src="/img/python-types/image03.png">
    
    ## More motivation
    
    Check this function, it already has type hints:
    
    {* ../../docs_src/python_types/tutorial003.py hl[1] *}
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 26 11:47:53 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

            .pingInterval(Duration.ofMillis(500))
            .build()
    
        // Set up the server to ignore the socket. It won't respond to pings!
        server.enqueue(MockResponse(socketPolicy = StallSocketAtStart))
    
        // Make a call. It'll fail as soon as our pings detect a problem.
        val call = client.newCall(Request(server.url("/")))
        val executeAtNanos = System.nanoTime()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  9. internal/grid/grid_test.go

    		return nil
    	})
    	if !errors.Is(err, context.Canceled) {
    		t.Error("expected context.Canceled, got", err)
    	}
    }
    
    // testServerStreamNoPing will test if server and client handle no pings.
    func testServerStreamNoPing(t *testing.T, local, remote *Manager, inCap int) {
    	defer testlogger.T.SetErrorTB(t)()
    	errFatal := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  10. docs/changelogs/changelog_4x.md

    ## Version 4.3.0
    
    _2019-12-31_
    
     *  Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact
        the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after
        a stream timeout to determine whether the connection should remain eligible for pooling.
    
     *  Fix: Don't call `EventListener.responseHeadersStart()` or `responseBodyStart()` until bytes have
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
Back to top