- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for unwrap (0.21 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
@Throws(InterruptedException::class) fun takeRequest(): RecordedRequest { return delegate.takeRequest().unwrap() } @Throws(InterruptedException::class) fun takeRequest( timeout: Long, unit: TimeUnit, ): RecordedRequest? { return delegate.takeRequest(timeout, unit)?.unwrap() } @JvmName("-deprecated_requestCount") @Deprecated( message = "moved to val",
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 5.9K 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 Apr 26 11:42:10 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SessionReuseTest.kt
} } } } client = client.newBuilder() .connectionSpecs(listOf(spec)) .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) {
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) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
private val eventListener = RecordingEventListener() private val listener = EventSourceRecorder() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(eventListener)) .build() @BeforeEach fun before(server: MockWebServer) { this.server = server } @AfterEach fun after() { listener.assertExhausted() } @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() private val executorService = Executors.newScheduledThreadPool(1) @BeforeEach fun setUp(server: MockWebServer) { this.server = server platform.assumeNotOpenJSSE()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/JSSETest.kt
@Disabled fun testFacebook() { val sessionIds = mutableListOf<String>() assumeNetwork() client = client.newBuilder() .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 5.4K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
2F12 ; mapped ; 529B # 3.0 KANGXI RADICAL POWER 2F13 ; mapped ; 52F9 # 3.0 KANGXI RADICAL WRAP 2F14 ; mapped ; 5315 # 3.0 KANGXI RADICAL SPOON 2F15 ; mapped ; 531A # 3.0 KANGXI RADICAL RIGHT OPEN BOX
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Feb 10 11:25:47 GMT 2024 - 854.1K bytes - Viewed (2)