- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 74 for conceal (0.17 sec)
-
okhttp/src/test/java/okhttp3/DuplexTest.kt
assertFailsWith<IOException> { requestBody.writeUtf8("request body\n") requestBody.flush() }.also { expected -> assertThat(expected.message) .isEqualTo("stream was reset: CANCEL") } body.awaitSuccess() assertThat(listener.recordedEventTypes()).containsExactly( "CallStart", "ProxySelectStart", "ProxySelectEnd", "DnsStart", "DnsEnd", "ConnectStart",
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) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
""" |data: hey | | """.trimMargin(), ).setHeader("content-type", "text/event-stream") .build(), ) listener.enqueueCancel() // Will cancel in onOpen(). newEventSource() listener.assertOpen() listener.assertFailure("canceled") } @Test fun badContentType() { server.enqueue( MockResponse.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private val controlFrameBuffer = Buffer() private val messageFrameBuffer = Buffer() /** Lazily initialized on first use. */ private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt
encodings[ 0x15] = encoding // Negative Acknowledgment encodings[ 0x16] = encoding // Synchronous idle encodings[ 0x17] = encoding // End of Transmission Block encodings[ 0x18] = encoding // Cancel encodings[ 0x19] = encoding // End of Medium encodings[ 0x1a] = encoding // Substitute encodings[ 0x1b] = encoding // Escape encodings[ 0x1c] = encoding // File Separator
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val connectionClose = CountDownLatch(1) val streams = object : RealWebSocket.Streams(false, source, sink) { override fun close() = connectionClose.countDown() override fun cancel() { socket.closeQuietly() } } val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = fancyRequest,
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/src/main/kotlin/okhttp3/EventListener.kt
* occur after a call is canceled. Typically cancellation takes effect when an expensive I/O * operation is required. * * This is invoked at most once, even if [Call.cancel] is invoked multiple times. It may be * invoked at any point in a call's life, including before [callStart] and after [callEnd]. */ open fun canceled(call: Call) { } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final class okhttp3/CacheControl$Companion { public final fun parse (Lokhttp3/Headers;)Lokhttp3/CacheControl; } public abstract interface class okhttp3/Call : java/lang/Cloneable { public abstract fun cancel ()V public abstract fun clone ()Lokhttp3/Call; public abstract fun enqueue (Lokhttp3/Callback;)V public abstract fun execute ()Lokhttp3/Response; public abstract fun isCanceled ()Z public abstract fun isExecuted ()Z
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "take plan 1", "plan 1 TCP connecting...", ) taskFaker.advanceUntil(500.ms) assertEvents( "take plan 2", "plan 0 cancel", "plan 1 cancel", ) taskFaker.advanceUntil(510.ms) assertEvents( "plan 1 TCP connect canceled", ) taskFaker.advanceUntil(520.ms) assertEvents(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} private fun cancelLater( call: Call, delayMillis: Int, ): CountDownLatch { val latch = CountDownLatch(1) Thread { sleep(delayMillis) if (cancelMode == CANCEL) { call.cancel() } else { threadToCancel!!.interrupt() } latch.countDown() }.apply { start() } return latch } companion object {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp-coroutines/README.md
that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call. Cancelling a call, will throw a CancellationException
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Nov 09 15:47:27 GMT 2023 - 609 bytes - Viewed (0)