- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 145 for straum (0.18 sec)
-
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/RealStream.kt
*/ package mockwebserver3.internal.duplex import mockwebserver3.Stream import okhttp3.internal.http2.ErrorCode import okhttp3.internal.http2.Http2Stream import okio.buffer /** Adapt OkHttp's internal [Http2Stream] type to the public [Stream] type. */ internal class RealStream( private val http2Stream: Http2Stream, ) : Stream { override val requestBody = http2Stream.getSource().buffer()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Dec 31 18:24:52 GMT 2022 - 1.1K 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 Apr 26 11:42:10 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} } /** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
// timeout is hit we like to tear down the whole stream. private const val SOURCE_UPSTREAM = 1 private const val SOURCE_FILE = 2 @JvmField val PREFIX_CLEAN = "OkHttp cache v1\n".encodeUtf8() @JvmField val PREFIX_DIRTY = "OkHttp DIRTY :(\n".encodeUtf8() private const val FILE_HEADER_SIZE = 32L /** * Creates a new relay that reads a live stream from [upstream], using [file] to share that data
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
| """.trimMargin(), ).setHeader("content-type", "text/event-stream") .build(), ) newEventSource() listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() assertThat(server.takeRequest().headers["Accept"]) .isEqualTo("text/event-stream") } @Test fun eventListenerEvents() { server.enqueue(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
private val BINARY = Array(256) { format("%8s", Integer.toBinaryString(it)).replace(' ', '0') } init { FLAGS[FLAG_NONE] = "" FLAGS[FLAG_END_STREAM] = "END_STREAM" val prefixFlags = intArrayOf(FLAG_END_STREAM) FLAGS[FLAG_PADDED] = "PADDED" for (prefixFlag in prefixFlags) { FLAGS[prefixFlag or FLAG_PADDED] = FLAGS[prefixFlag] + "|PADDED" }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
internal/grid/README.md
conn := manager.Connection(host).Subroute("asubroute") payload := []byte("request") stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload) if err != nil { return err } // Read results from the stream err = stream.Results(func(result []byte) error { fmt.Println("Got result", string(result)) // Return the response for reuse
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0)