- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for wrap (0.21 sec)
-
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) -
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/MockWebServer.kt
var serverSocketFactory: ServerSocketFactory? by delegate::serverSocketFactory var dispatcher: Dispatcher = QueueDispatcher() set(value) { field = value delegate.dispatcher = value.wrap() } val port: Int get() { before() // This implicitly starts the delegate. return delegate.port } val hostName: String get() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 5.9K bytes - Viewed (0) -
docs/en/docs/advanced/wsgi.md
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 1.1K 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/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/ConnectionCoalescingTest.kt
Interceptor { chain: Interceptor.Chain? -> connection.set(chain!!.connection()) chain.proceed(chain.request()) }, ) .eventListenerFactory(clientTestRule.wrap(listener1)) .build() val request = Request.Builder().url(sanUrl).build() val call1 = client1.newCall(request) call1.enqueue( object : Callback { @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K 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)