- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 1,307 for Callable (0.06 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 eitherCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8.3K bytes - Click Count (0)