Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 458 for CALL (0.03 sec)

  1. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       * [synchronously][Call.execute] and [asynchronously][Call.enqueue].
       */
      fun cancelAll() {
        this.withLock {
          for (call in readyAsyncCalls) {
            call.call.cancel()
          }
          for (call in runningAsyncCalls) {
            call.call.cancel()
          }
          for (call in runningSyncCalls) {
            call.cancel()
          }
        }
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. fastapi/dependencies/utils.py

            elif is_gen_callable(call) or is_async_gen_callable(call):
                solved = await solve_generator(
                    call=call, stack=async_exit_stack, sub_values=solved_result.values
                )
            elif is_coroutine_callable(call):
                solved = await call(**solved_result.values)
            else:
                solved = await run_in_threadpool(call, **solved_result.values)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 21:46:26 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        ListenableFuture<Boolean> future2 =
            serializer.submit(
                new Callable<Boolean>() {
                  @Override
                  public Boolean call() {
                    return blockingCallable.isRunning();
                  }
                },
                directExecutor());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    	return respBody, nil
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is disconnected
    // and a healthcheck routine gets invoked that would reconnect.
    func (client *storageRESTClient) call(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) {
    	if values == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/testing-dependencies.md

    An example could be that you have an external authentication provider that you need to call.
    
    You send it a token and it returns an authenticated user.
    
    This provider might be charging you per request, and calling it might take some extra time than if you had a fixed mock user for tests.
    
    You probably want to test the external provider once, but not necessarily call it for every test that runs.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. cmd/lock-rest-client.go

    	return c.call(ctx, lockRPCRLock, &args)
    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    
    // RUnlock calls read unlock REST API.
    func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRUnlock, &args)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        join();
    
        if (uncaughtThrowable != null) {
          throw new AssertionError("Uncaught throwable in " + getName(), 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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      public void testReturning() throws Exception {
        assertNull(Callables.returning(null).call());
    
        Object value = new Object();
        Callable<Object> callable = Callables.returning(value);
        assertSame(value, callable.call());
        // Expect the same value on subsequent calls
        assertSame(value, callable.call());
      }
    
      @J2ktIncompatible
      @GwtIncompatible
      public void testAsAsyncCallable() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

         *     {@link #whenAllComplete(Iterable)} or {@link #whenAllComplete(Iterable)}
         * @throws IllegalStateException if called outside of a call to {@link
         *     CombiningCallable#call(DeferredCloser, Peeker)} or {@link
         *     AsyncCombiningCallable#call(DeferredCloser, Peeker)}
         */
        @ParametricNullness
        public final <D extends @Nullable Object> D getDone(ClosingFuture<D> closingFuture)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
Back to top