- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for reorder (0.15 sec)
-
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
// We know that a fresh connection was created if the server recorded a request with sequence // number 0. Since the client may have attempted to reuse the broken connection just before // creating a fresh connection, the server may have recorded 2 requests at this point. The order // of recording is non-deterministic. val requestAfter = server.takeRequest() assertThat(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
CHANGELOG.md
its own IDN mapping table in the library. * New: Prefer the client's configured precedence order for TLS cipher suites. (OkHttp used to prefer the JDK’s precedence order.) This change may cause your HTTP calls to negotiate a different cipher suite than before! OkHttp's defaults cipher suites are selected for good security and performance.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* * Since we can't ACK settings on the current reader thread (the reader thread can't write) we * execute all peer settings logic on the writer thread. This relies on the fact that the * writer task queue won't reorder tasks; otherwise settings could be applied in the opposite * order than received. */ fun applyAndAckSettings( clearPrevious: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
if (body != null) { assertThat(event.responseBody).isEqualTo(body) } assertThat(event.t.javaClass).isEqualTo(cls) assertThat(event.t.message).isEqualTo(message) } /** Expose this recorder as a frame callback and shim in "ping" events. */ fun asFrameCallback() = object : WebSocketReader.FrameCallback { override fun onReadMessage(text: String) { events.add(Message(string = text))
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/RecordingCallback.kt
response: Response, ) { val body = response.body.string() responses.add(RecordedResponse(call.request(), response, null, body, null)) (this as Object).notifyAll() } /** * Returns the recorded response triggered by `request`. Throws if the response isn't * enqueued before the timeout. */ @Synchronized fun await(url: HttpUrl): RecordedResponse {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
* multiple requests, each request is assigned its own sequence number. */ val sequenceNumber: Int, socket: Socket, /** * The failure MockWebServer recorded when attempting to decode this request. If, for example, * the inbound request was truncated, this exception will be non-null. */ val failure: IOException? = null, ) { val method: String? val path: String?
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.8K bytes - Viewed (1) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
assertThat(response.contentAsString).isEqualTo("hello, Jetty HTTP Client") val recorded = server.takeRequest() assertThat(recorded.headers["Accept"]).isEqualTo("text/plain") assertThat(recorded.headers["Accept-Encoding"]).isEqualTo("gzip") assertThat(recorded.headers["Connection"]).isNull() assertThat(recorded.headers["User-Agent"]!!).matches(Regex("Jetty/.*")) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) } /** * Removes recorded events up to (and including) an event is found whose class equals [eventClass] * and returns it. */ fun <T : CallEvent> removeUpToEvent(eventClass: Class<T>): T { val fullEventSequence = eventSequence.toList()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9K bytes - Viewed (1) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
override fun publish(record: LogRecord) { val recorded = when (record.loggerName) { TaskRunner::class.java.name -> recordTaskRunner Http2::class.java.name -> recordFrames "javax.net.ssl" -> recordSslDebug && !sslExcludeFilter.matches(record.message) else -> false } if (recorded) { synchronized(clientEventsList) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordedResponse.kt
import assertk.assertions.isNull import assertk.assertions.isTrue import java.io.IOException import java.text.SimpleDateFormat import java.util.Date /** * A received response or failure recorded by the response recorder. */ class RecordedResponse( @JvmField val request: Request, val response: Response?, val webSocket: WebSocket?, val body: String?, val failure: IOException?, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0)