- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for sekund (0.17 sec)
-
okhttp/src/test/java/okhttp3/DuplexTest.kt
requestBody1.flush() }.also { expected -> assertThat(expected.message) .isEqualTo("stream was reset: CANCEL") } body1.awaitSuccess() // Second duplex request proceeds normally. val requestBody2 = (call.request().body as AsyncRequestBody?)!!.takeSink() requestBody2.writeUtf8("request body\n") requestBody2.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt
.callTimeout(10, TimeUnit.SECONDS) .build() fun run() { val request = Request.Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build() client.newCall(request).execute().use { response -> println("Response completed: $response") } } } fun main() { ConfigureTimeouts().run()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java
private final OkHttpClient client = new OkHttpClient(); public void run() throws Exception { Request request = new Request.Builder() .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. .build(); // Copy to customize OkHttp for this request. OkHttpClient client1 = client.newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build();
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun May 22 01:29:42 GMT 2016 - 1.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val endsFirst = buildRequestThread(secondRequest, secondResponseCode) endsFirst.start() endsFirst.join() // First response is still waiting. assertThat(firstResponseCode.get()).isEqualTo(0) // Second response is done. assertThat(secondResponseCode.get()).isEqualTo(200) latch.countDown() startsFirst.join() // And now it's done! assertThat(firstResponseCode.get()).isEqualTo(200) // (Still done).
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
): RecordedRequest? = requestQueue.poll(timeout, unit) /** * Scripts [response] to be returned to a request made in sequence. The first request is * served by the first enqueued response; the second request by the second enqueued response; and * so on. * * @throws ClassCastException if the default dispatcher has been * replaced with [setDispatcher][dispatcher]. */
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) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt
private fun skipName(source: Buffer) { // 0 - 63 bytes var length = source.readByte().toInt() if (length < 0) { // compressed name pointer, first two bits are 1 // drop second byte of compression offset source.skip(1) } else { while (length > 0) { // skip each part of the domain name source.skip(length.toLong()) length = source.readByte().toInt()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
var finished: Boolean = false, ) : Sink { /** * Buffer of outgoing data. This batches writes of small writes into this sink as larges frames * written to the outgoing connection. Batching saves the (small) framing overhead. */ private val sendBuffer = Buffer() /** Trailers to send at the end of the stream. */
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/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} } if (!acquired) continue // Confirm the connection is healthy and return it. if (connection.isHealthy(doExtensiveHealthChecks)) return connection // In the second synchronized block, release the unhealthy acquired connection. We're also on // the hook to close this connection if it's no longer in use. val noNewExchangesEvent: Boolean val toClose: Socket? =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
.addHeader("Set-Cookie: a=SECOND") .code(HttpURLConnection.HTTP_NOT_MODIFIED) .build(), ) val url = server.url("/") assertThat(get(url).body.string()).isEqualTo("A") cookieJar.assertResponseCookies("a=FIRST; path=/") assertThat(get(url).body.string()).isEqualTo("A") cookieJar.assertResponseCookies("a=SECOND; path=/") } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0)