Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 1,307 for Callable (0.06 seconds)

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

      private static final long NOT_ENOUGH_MS = 5;
    
      private static final String GOOD_CALLABLE_RESULT = "good callable result";
      private static final Callable<String> GOOD_CALLABLE =
          () -> {
            MILLISECONDS.sleep(DELAY_MS);
            return GOOD_CALLABLE_RESULT;
          };
      private static final Callable<String> BAD_CALLABLE =
          () -> {
            MILLISECONDS.sleep(DELAY_MS);
            throw new SampleException();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 9.4K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit test for {@link FakeTimeLimiter}.
     *
     * @author Jens Nyman
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit test for {@link FakeTimeLimiter}.
     *
     * @author Jens Nyman
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.1K bytes
    - Click Count (0)
  4. guava/src/com/google/common/cache/AbstractLoadingCache.java

    import com.google.common.util.concurrent.UncheckedExecutionException;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    
    /**
     * This class provides a skeletal implementation of the {@code Cache} interface to minimize the
     * effort required to implement this interface.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ListenableFuture<@Nullable Void> unused =
            serializer.submitAsync(() -> settableFuture, directExecutor());
        for (int i = 0; i < 25_000; i++) {
          serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
          unused = serializer.submit(Callables.returning(null), directExecutor());
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  6. docs/en/docs/reference/security/index.md

    # Security Tools
    
    When you need to declare dependencies with OAuth2 scopes you use `Security()`.
    
    But you still need to define what is the dependable, the callable that you pass as a parameter to `Depends()` or `Security()`.
    
    There are multiple tools that you can use to create those dependables, and they get integrated into OpenAPI so they are shown in the automatic docs UI, they can be used by automatically generated clients and SDKs, etc.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Feb 04 12:41:54 GMT 2026
    - 1.7K bytes
    - Click Count (0)
  7. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/LicensingPlugin.java

    import org.gradle.api.provider.Property;
    import org.gradle.api.provider.Provider;
    import org.gradle.api.provider.ProviderFactory;
    
    import javax.inject.Inject;
    import java.util.Map;
    import java.util.concurrent.Callable;
    
    public class LicensingPlugin implements Plugin<Project> {
        final static String ELASTIC_LICENSE_URL_PREFIX = "https://raw.githubusercontent.com/elastic/elasticsearch/";
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  8. fastapi/dependencies/utils.py

                raise RuntimeError(multipart_not_installed_error) from None
    
    
    def get_parameterless_sub_dependant(*, depends: params.Depends, path: str) -> Dependant:
        assert callable(depends.dependency), (
            "A parameter-less dependency must have a callable dependency"
        )
        own_oauth_scopes: list[str] = []
        if isinstance(depends, params.Security) and depends.scopes:
            own_oauth_scopes.extend(depends.scopes)
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 38.7K bytes
    - Click Count (3)
  9. src/test/java/jcifs/SmbWatchHandleTest.java

            assertEquals(3, result.size());
            verify(watchHandle, times(1)).call();
        }
    
        /**
         * Test call() method as Callable in executor service
         */
        @Test
        void testCallAsCallable() throws Exception {
            // Create a real implementation for testing Callable behavior
            SmbWatchHandle realHandle = new SmbWatchHandle() {
                private int callCount = 0;
    
                @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.2K bytes
    - Click Count (1)
  10. android/guava/src/com/google/common/cache/Cache.java

    import java.util.Map;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ExecutionException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A semi-persistent mapping from keys to values. Cache entries are manually added using {@link
     * #get(Object, Callable)} or {@link #put(Object, Object)}, and are stored in the cache until either
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8.3K bytes
    - Click Count (0)
Back to Top