- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for ready (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // Fill the receive buffer without holding any locks. val read = source.read(receiveBuffer, remainingByteCount) if (read == -1L) throw EOFException() remainingByteCount -= read // Move the received data to the read buffer to the reader can read it. If this source has // been closed since this read began we must discard the incoming data and tell the // connection we've done so.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/CallTest.kt
call: Call, response: Response, ) { val bytes = response.body.byteStream() assertThat(bytes.read()).isEqualTo('a'.code) assertThat(bytes.read()).isEqualTo('b'.code) assertThat(bytes.read()).isEqualTo('c'.code) // This request will share a connection with 'A' cause it's all done.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val source = relay.newSource() val sourceBuffer = Buffer() assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5) assertThat(sourceBuffer.readUtf8()).isEqualTo("abcde") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(8) assertThat(sourceBuffer.readUtf8()).isEqualTo("fghijklm") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(-1) assertThat(sourceBuffer.size).isEqualTo(0) source.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
private val message: String private val responseHeaders: Headers private val handshake: Handshake? private val sentRequestMillis: Long private val receivedResponseMillis: Long /** * Reads an entry from an input stream. A typical entry looks like this: * * ``` * http://google.com/foo * GET * 2 * Accept-Language: fr-CA * Accept-Charset: UTF-8
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
request: UrlRequest, info: UrlResponseInfo, ) { println("onResponseStarted ${info.headers.asMap} ${info.negotiatedProtocol}") request.read(ByteBuffer.allocateDirect(4096 * 8)) } override fun onReadCompleted( request: UrlRequest, info: UrlResponseInfo, byteBuffer: ByteBuffer, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 24 13:19:43 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val response = call.execute() val inputStream = response.body.byteStream() assertThat(inputStream.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo(-1) assertThat(inputStream.read()).isEqualTo(-1) inputStream.close() } @ParameterizedTest
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Request.kt
/** * Attaches [tag] to the request using [T] as a key. Tags can be read from a request using * [Request.tag]. Use null to remove any existing tag assigned for [T]. * * Use this API to attach timing, debugging, or other application data to a request so that * you may read it in interceptors, event listeners, or callbacks. */ @JvmName("reifiedTag")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:17:44 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() assertThat(client.closed).isFalse() server.processNextFrame() // Read client closing, send server close. server.listener.assertClosing(1000, "Hello!") server.webSocket!!.finishReader() server.webSocket!!.close(1000, "Goodbye!") client.processNextFrame() // Read server closing, close connection. taskFaker.runTasks() client.listener.assertClosing(1000, "Goodbye!")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
.github/workflows/docs.yml
name: docs on: push: branches: - master pull_request: types: [opened, labeled, unlabeled, synchronize] permissions: contents: read env: GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false" jobs: test_docs: permissions: checks: write # for actions/upload-artifact runs-on: ubuntu-latest
Others - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 04 06:13:36 GMT 2024 - 1K bytes - Viewed (0)