- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 236 for Ball (0.29 sec)
-
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
runTest { val call = ClosableCall() supervisorScope { assertFailsWith<CancellationException> { coroutineScope { call.afterCallbackOnResponse = { coroutineContext.job.cancel() } call.executeAsync() } } } assertThat(call.canceled).isTrue()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 5.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
) : EventSource, ServerSentEventReader.Callback, Callback { private var call: Call? = null @Volatile private var canceled = false fun connect(callFactory: Call.Factory) { call = callFactory.newCall(request).apply { enqueue(this@RealEventSource) } } override fun onResponse( call: Call, response: Response, ) { processResponse(response) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
} else { null } } override fun secureConnectStart(call: Call) { // Register to capture "Produced ClientHello handshake message". currentThread = Thread.currentThread() logger.addHandler(loggerHandler) } override fun secureConnectEnd( call: Call, handshake: Handshake?, ) { logger.removeHandler(loggerHandler) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
get() = countingSource.bytesRead - source.buffer.size /** How many bytes to read before [peekHeader] should return false, or -1L for no limit. */ private var limit = -1L /** Type hints scoped to the call stack, manipulated with [withTypeHint]. */ private val typeHintStack = mutableListOf<Any?>() /** * The type hint for the current object. Used to pick adapters based on other fields, such as
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
acceptConnections() } catch (e: Throwable) { logger.log(Level.WARNING, "$this failed unexpectedly", e) } // Release all sockets and all threads, even if any close fails. serverSocket?.closeQuietly() val openClientSocket = openClientSockets.iterator() while (openClientSocket.hasNext()) {
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) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
.throttleBody((64 * 1024).toLong(), 125, TimeUnit.MILLISECONDS), ) // 500 Kbps server.start() val call = client.newCall( Request.Builder() .url(server.url("/")) .build(), ) val response = call.execute() interruptLater(500) val responseBody = response.body.byteStream() val buffer = ByteArray(1024)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
public fun cacheConditionalHit (Lokhttp3/Call;Lokhttp3/Response;)V public fun cacheHit (Lokhttp3/Call;Lokhttp3/Response;)V public fun cacheMiss (Lokhttp3/Call;)V public fun callEnd (Lokhttp3/Call;)V public fun callFailed (Lokhttp3/Call;Ljava/io/IOException;)V public fun callStart (Lokhttp3/Call;)V public fun canceled (Lokhttp3/Call;)V
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* Process the next protocol frame. * * * If it is a control frame this will result in a single call to [FrameCallback]. * * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage]. * If the message spans multiple frames, each interleaved control frame will result in a * corresponding call to [FrameCallback]. */ @Throws(IOException::class) fun processNextFrame() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SessionReuseTest.kt
.connectionSpecs(listOf(spec)) .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { val sslSocket = connection.socket() as SSLSocket sessionIds.add(sslSocket.session.id.toByteString().hex())
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 6K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/logging/LoggingUtil.kt
} } } if (debug) { handler.level = Level.ALL handler.formatter = OneLineLogFormat() val activeLogger = getLogger("") activeLogger.addHandler(handler) activeLogger.level = Level.ALL getLogger("jdk.event.security").level = Level.INFO getLogger("org.conscrypt").level = Level.INFO } else {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.7K bytes - Viewed (1)