- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for flowControlListener (0.39 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.http2 import okhttp3.internal.http2.flowcontrol.WindowCounter interface FlowControlListener { /** * Notification that the receiving stream flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/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 { return Http2Connection(this) } } /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/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, source, sink) .listener(this) .pingIntervalMillis(pingIntervalMillis) .flowControlListener(flowControlListener) .build()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 15.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/http2/Http2FlowControlConnectionListener.kt
import okhttp3.internal.http2.flowcontrol.WindowCounter /** * ConnectionListener that outputs CSV for flow control of client receiving streams. */ class Http2FlowControlConnectionListener : ConnectionListener(), FlowControlListener { val start = System.currentTimeMillis() override fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0)