Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for BOOM (0.08 sec)

  1. okhttp/src/test/java/okhttp3/InterceptorTest.kt

       * exception goes to the uncaught exception handler.
       */
      private fun interceptorThrowsRuntimeExceptionAsynchronous(network: Boolean) {
        val boom = RuntimeException("boom!")
        addInterceptor(network) { chain: Interceptor.Chain? -> throw boom }
        val executor = ExceptionCatchingExecutor()
        client =
          client.newBuilder()
            .dispatcher(Dispatcher(executor))
            .build()
        val request =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        plan0.tcpConnectThrowable = IOException("boom 0!")
        val plan1 = routePlanner.addPlan()
        plan1.tcpConnectThrowable = IOException("boom 1!")
    
        taskRunner.newQueue().execute("connect") {
          assertFailsWith<IOException> {
            finder.find()
          }.also { expected ->
            assertThat(expected).hasMessage("boom 0!")
            assertThat(expected.suppressed.single()).hasMessage("boom 1!")
          }
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/DuplexTest.kt

            .exhaustResponse()
        server.enqueue(
          MockResponse.Builder()
            .clearHeaders()
            .addHeader("h1", "v1")
            .addHeader("h2", "v2")
            .trailers(headersOf("trailers", "boom"))
            .streamHandler(body)
            .build(),
        )
        val call =
          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .build(),
          )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        Exception::class,
      )
      fun throwingOnFailLogs() {
        webServer.enqueue(
          MockResponse.Builder()
            .code(200)
            .body("Body")
            .build(),
        )
        val e = RuntimeException("boom")
        clientListener.setNextEventDelegate(
          object : WebSocketListener() {
            override fun onFailure(
              webSocket: WebSocket,
              t: Throwable,
              response: Response?,
            ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

                    // to
                    // ensure that the thread running the failure callbacks is not the main thread.
                    Uninterruptibles.awaitUninterruptibly(afterStarted);
                    notifyFailed(new Exception("boom"));
                  }
                }.start();
              }
    
              @Override
              protected void doStop() {
                notifyStopped();
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
Back to top