Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for onRequestStart (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

                }
              },
            ).build()
    
        // Set up a same-connection retry.
        serverIpv4.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode))
            .build(),
        )
        serverIpv4.enqueue(
          MockResponse(body = "this was the 2nd request on IPv4"),
        )
        serverIpv6.enqueue(
    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)
  5. okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt

      val dns = FakeDns()
    
      val ipv4 = InetAddress.getByName("203.0.113.1")
      val ipv6 = InetAddress.getByName("2001:db8:ffff:ffff:ffff:ffff:ffff:1")
    
      val refusedStream =
        MockResponse
          .Builder()
          .onRequestStart(CloseStream(ErrorCode.REFUSED_STREAM.httpCode))
          .build()
      val bodyResponse = MockResponse(body = "body")
    
      @BeforeEach
      fun setUp() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jan 10 15:25:06 GMT 2026
    - 11.8K bytes
    - Click Count (0)
  6. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

      }
    
      @Disabled("Not actually failing where expected")
      @Test
      fun disconnectAtStart() {
        server.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseSocket())
            .build(),
        )
        server.enqueue(MockResponse()) // The jdk's HttpUrlConnection is a bastard.
        server.enqueue(MockResponse())
        try {
          server
            .url("/a")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          } catch (e: SocketException) {
            logger.fine("${this@MockWebServer} done accepting connections: ${e.message}")
            return
          }
    
          val peek = dispatcher.peek()
          if (peek.onRequestStart is CloseSocket) {
            dispatchBookkeepingRequest(
              connectionIndex = nextConnectionIndex++,
              exchangeIndex = 0,
              socket = MockWebServerSocket(socket),
            )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
  10. 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)
Back to Top