Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for flowControlListener (0.07 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        fun pingIntervalMillis(pingIntervalMillis: Int) =
          apply {
            this.pingIntervalMillis = pingIntervalMillis
          }
    
        fun flowControlListener(flowControlListener: FlowControlListener) =
          apply {
            this.flowControlListener = flowControlListener
          }
    
        fun build(): Http2Connection = Http2Connection(this)
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

        val flowControlListener = connectionListener as? FlowControlListener ?: FlowControlListener.None
        val http2Connection =
          Http2Connection
            .Builder(client = true, taskRunner)
            .socket(socket, route.address.url.host)
            .listener(this)
            .pingIntervalMillis(pingIntervalMillis)
            .flowControlListener(flowControlListener)
            .build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

                }
              } finally {
                if (doReadTimeout) {
                  readTimeout.exitAndThrowIfTimedOut()
                }
              }
            }
            connection.flowControlListener.receivingStreamWindowChanged(id, readBytes, readBuffer.size)
    
            // 2. Do it outside of the synchronized block and timeout.
    
            if (tryAgain) {
              continue
            }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top