Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 3,862 for Call (0.27 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      // as Combiner.
    
      public void testWhenAllSucceed_call_failedInput() throws Exception {
        assertFinallyFailsWithException(
            ClosingFuture.whenAllSucceed(
                    ImmutableList.of(
                        ClosingFuture.from(immediateFuture("value")), failedClosingFuture()))
                .call(
                    new CombiningCallable<Object>() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/es/config/bsbhv/BsWebConfigBhv.java

        public int[] batchInsert(List<WebConfig> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<WebConfig> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
        public int[] batchUpdate(List<WebConfig> list) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/TestThread.java

              new AssertionFailedError("Uncaught throwable in " + getName())
                  .initCause(uncaughtThrowable);
        }
      }
    
      /**
       * Causes this thread to call the named void method, and asserts that the call returns normally.
       */
      public void callAndAssertReturns(String methodName, Object... arguments) throws Exception {
        checkNotNull(methodName);
        checkNotNull(arguments);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

          for (PerListenerQueue<L> queue : listeners) {
            queue.add(event, label);
          }
        }
      }
    
      /**
       * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
       *
       * <p>Note: this method is idempotent and safe to call from any thread
       */
      public void dispatch() {
        // iterate by index to avoid concurrent modification exceptions
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 8.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

            .build()
        val latch = CountDownLatch(1)
        val exceptionRef = AtomicReference<Throwable>()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        call.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              exceptionRef.set(e)
              latch.countDown()
            }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

        call.plansToCancel -= connectPlan
      }
    
      override fun updateRouteDatabaseAfterSuccess(route: Route) {
        call.client.routeDatabase.connected(route)
      }
    
      override fun connectStart(route: Route) {
        eventListener.connectStart(call, route.socketAddress, route.proxy)
        poolConnectionListener.connectStart(route, call)
      }
    
      override fun connectFailed(
        route: Route,
        protocol: Protocol?,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          // the exception immediately
    
          // Register a listener on each Future in the list to update the state of this future.
          // Note that if all the futures on the list are done prior to completing this loop, the last
          // call to addListener() will callback to setOneValue(), transitively call our cleanup
          // listener, and set this.futures to null.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      // as Combiner.
    
      public void testWhenAllSucceed_call_failedInput() throws Exception {
        assertFinallyFailsWithException(
            ClosingFuture.whenAllSucceed(
                    ImmutableList.of(
                        ClosingFuture.from(immediateFuture("value")), failedClosingFuture()))
                .call(
                    new CombiningCallable<Object>() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  9. android-test-app/src/main/kotlin/okhttp/android/testapp/MainActivity.kt

        client.newCall(Request(url)).enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              println("failed: $e")
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              println("response: ${response.code}")
              response.close()
            }
          },
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/EventListenerTest.kt

            .build(),
        )
        val call =
          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .build(),
          )
        call.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 56.9K bytes
    - Viewed (0)
Back to top