- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for iostream (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
import okio.Source import okio.Timeout /** * Replicates a single upstream source into multiple downstream sources. Each downstream source * returns the same bytes as the upstream source. Downstream sources may read data either as it * is returned by upstream, or after the upstream source has been exhausted. * * As bytes are returned from upstream they are written to a local file. Downstream sources read * from this file as necessary.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
deploy_website.sh
mkdocs gh-deploy # Restore Javadocs from 1.x, 2.x, and 3.x. git checkout gh-pages git cherry-pick bb229b9dcc9a21a73edbf8d936bea88f52e0a3ff git cherry-pick c695732f1d4aea103b826876c077fbfea630e244 git push --set-upstream origin gh-pages # Delete our temp folder cd ..
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Nov 20 15:26:12 GMT 2023 - 1.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
return socket.isHealthy(source) } return true } /** Refuse incoming streams. */ @Throws(IOException::class) override fun onStream(stream: Http2Stream) { stream.close(ErrorCode.REFUSED_STREAM, null) } /** When settings are received, adjust the allocation limit. */ override fun onSettings( connection: Http2Connection, settings: Settings, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
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.
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) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
sleepNanos(response.headersDelayNanos) stream.writeHeaders(response.toHttp2Headers(), outFinished, flushHeaders) if (trailers.size > 0) { stream.enqueueTrailers(trailers) } pushPromises(stream, request, response.pushPromises) if (body != null) { sleepNanos(bodyDelayNanos) val responseBodySink = stream.getSink().withThrottlingAndSocketPolicy(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt
*/ @ExperimentalOkHttpApi interface Stream { val requestBody: BufferedSource val responseBody: BufferedSink /** * Terminate the stream so that no further data is transmitted or received. Note that * [requestBody] may return data after this call; that is the buffered data received before this * stream was canceled. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
if (file.isDirectory) { serveDirectory(stream, file.listFiles()!!) } else if (file.exists()) { serveFile(stream, file) } else { send404(stream, path) } } catch (e: IOException) { Platform.get().log("Failure serving Http2Stream: " + e.message, Platform.INFO, null) } } private fun send404( stream: Http2Stream, path: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM on stream 1 for (i in 0 until framesThatFillWindow) { peer.acceptFrame() // DATA on stream 1 } peer.acceptFrame() // SYN_STREAM on stream 2 peer.acceptFrame() // DATA on stream 2 peer.play() // Play it back. val connection = connect(peer) val stream1 = connection.newStream(headerEntries("a", "apple"), true)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
if (canceled) { stream!!.closeLater(ErrorCode.CANCEL) throw IOException("Canceled") } stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS) stream!!.writeTimeout().timeout(chain.writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS) } override fun flushRequest() { http2Connection.flush() } override fun finishRequest() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
assertThat(formattedFlags).containsExactly( "", "END_STREAM", "00000010", "00000011", "END_HEADERS", "END_STREAM|END_HEADERS", "00000110", "00000111", "PADDED", "END_STREAM|PADDED", "00001010", "00001011", "00001100", "END_STREAM|END_HEADERS|PADDED", "00001110", "00001111", "00010000",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0)