- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Wrap (0.28 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* the request completes normally or when it fails due to an exception, in which case [e] should * be non-null. * * If the exchange was canceled or timed out, this will wrap [e] in an exception that provides * that additional context. Otherwise [e] is returned as-is. */ internal fun <E : IOException?> messageDone( exchange: Exchange, requestDone: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server platform.assumeNotOpenJSSE()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
.build() // Need fresh client to reset sslSocketFactoryOrNull client = OkHttpClient.Builder() .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import mockwebserver3.SocketPolicy.StallSocketAtStart internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() { override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse { return delegate.dispatch(request.unwrap()).wrap() } override fun peek(): mockwebserver3.MockResponse {
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/concurrent/TaskQueue.kt
} else { "scheduled after ${formatDuration(executeNanoTime - now)}" } } // Insert in chronological order. Always compare deltas because nanoTime() is permitted to wrap. var insertAt = futureTasks.indexOfFirst { it.nextExecuteNanoTime - now > delayNanos } if (insertAt == -1) insertAt = futureTasks.size futureTasks.add(insertAt, task)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
Logger.getLogger(TaskRunner::class.java.name).fn() Logger.getLogger("javax.net.ssl").fn() } fun wrap(eventListener: EventListener) = EventListener.Factory { ClientRuleEventListener(eventListener, ::addEvent) } fun wrap(eventListenerFactory: EventListener.Factory) = EventListener.Factory { call -> ClientRuleEventListener(eventListenerFactory.create(call), ::addEvent) } /**
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/FastFallbackTest.kt
dnsResults = listOf( localhostIpv4, localhostIpv6, ) client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks. .dns { dnsResults } .fastFallback(true) .build() url = serverIpv4.url("/")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FormBodyTest.kt
assertThat(formEncode(128)).isEqualTo("%C2%80") assertThat(formEncode(255)).isEqualTo("%C3%BF") } @Throws(IOException::class) private fun formEncode(codePoint: Int): String { // Wrap the codepoint with regular printable characters to prevent trimming. val body = FormBody.Builder() .add("a", String(intArrayOf('b'.code, codePoint, 'c'.code), 0, 3)) .build()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
client = clientTestRule.newClientBuilder() .dns(dns) .socketFactory(socketFactory) .eventListenerFactory(clientTestRule.wrap(listener)) .build() } @Test fun http2OneBadHostOneGoodNoRetryOnConnectionFailure() { enableProtocol(Protocol.HTTP_2) val request = Request(server1.url("/"))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
* * If the hint is unknown [chooser] should return null which will cause the value to be decoded as * an opaque byte string. * * This may optionally wrap the contents in a tag. */ fun usingTypeHint(chooser: (Any?) -> DerAdapter<*>?): DerAdapter<Any?> { return object : DerAdapter<Any?> { override fun matches(header: DerHeader): Boolean = true
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0)