- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for onRequestStart (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
.setHeader("Sec-WebSocket-Accept", "ujmZX4KXZqjwy6vi1aQFH5p4Ygk=") .build(), ) webServer.enqueue( MockResponse .Builder() .onRequestStart(CloseSocket()) .build(), ) val webSocket = newWebSocket() clientListener.assertFailure( 101, null, ProtocolException::class.java,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
MockResponse .Builder() .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode)) .build(), ) server.enqueue( MockResponse .Builder() .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode)) .build(), ) server.enqueue( MockResponse .Builder() .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode))Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 67.5K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java
* @param request The request data. * @return The response data. */ @Override public ResponseData execute(final RequestData request) { if (listener != null) { listener.onRequestStart(this, request); } List<Exception> exceptionList = null; try { int count = 0; while (count < maxRetryCount) { if (listener != null) {Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Jul 06 02:13:03 GMT 2025 - 7.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Aug 03 22:38:00 GMT 2025 - 28K bytes - Click Count (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
), ) } SocketPolicy.STALL_SOCKET_AT_START -> { result.onRequestStart(SocketEffect.Stall) } SocketPolicy.NO_RESPONSE -> { result.onResponseStart(SocketEffect.Stall) } SocketPolicy.RESET_STREAM_AT_START -> { result.onRequestStart(CloseStream(http2ErrorCode)) } }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 4.3K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
} } /** https://github.com/square/okhttp/issues/4875 */ @Test fun interceptorRecoversWhenRoutesExhausted() { server.enqueue(MockResponse.Builder().onRequestStart(CloseSocket()).build()) server.enqueue(MockResponse()) client = client .newBuilder() .addInterceptor( Interceptor { chain: Interceptor.Chain ->
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
sinkReference.get().write("ghi".toByteArray()) sinkReference.get().emit() } } @Test fun getHeadersThrows() { server.enqueue(MockResponse.Builder().onRequestStart(CloseSocket()).build()) assertFailsWith<IOException> { getResponse(newRequest("/")) } } @Test fun dnsFailureThrowsIOException() { client = client
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0)