- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for AssertionError (0.17 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
} fun processNextFrame(): Boolean { taskFaker.runTasks() return webSocket!!.processNextFrame() } override fun close() { if (closed) { throw AssertionError("Already closed") } try { source.close() } catch (ignored: IOException) { } try { sink.close() } catch (ignored: IOException) { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
if (streamsToClose != null) { listener.onClosed(this, receivedCloseCode, receivedCloseReason!!) } } else { throw AssertionError() } return true } finally { writerToClose?.closeQuietly() streamsToClose?.closeQuietly() } } internal fun writePingFrame() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
// and resetting the stream. duplexResponseSent.await() } catch (e: InterruptedException) { throw AssertionError() } super.responseHeadersEnd(call, response) } } client = client.newBuilder() .eventListener(listener) .build() val body =
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/src/test/java/okhttp3/ConnectionCoalescingTest.kt
) { try { // Wait for request2 to guarantee we make 2 separate connections to the server. latch1.await() } catch (e: InterruptedException) { throw AssertionError(e) } } 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 - 18.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
responses.offer(response!!.body.string()) try { latch.await() } catch (e: InterruptedException) { throw AssertionError() } response.request } val blockingAuthClient = client.newBuilder() .authenticator(authenticator) .build() val callback: Callback =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/TestLogHandler.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/AndroidPlatform.kt
findByIssuerAndSignatureMethod.invoke( trustManager, cert, ) as TrustAnchor trustAnchor.trustedCert } catch (e: IllegalAccessException) { throw AssertionError("unable to get issues and signature", e) } catch (_: InvocationTargetException) { null } } } companion object { val isSupported: Boolean = when {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.2K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
// Confirm the interceptor isn't exercised. client = client.newBuilder() .addNetworkInterceptor(Interceptor { chain: Interceptor.Chain? -> throw AssertionError() }) .build() assertThat(get(url).body.string()).isEqualTo("A") } @Test fun iterateCache() { // Put some responses in the cache. server.enqueue(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)