- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 2,368 for Call (0.69 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
* until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. * * Typical use loops over the parts in sequence: * * ```kotlin * val response: Response = call.execute() * val multipartReader = MultipartReader(response.body!!) * * multipartReader.use { * while (true) { * val part = multipartReader.nextPart() ?: break * process(part.headers, part.body) * }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 02:11:14 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
private final Callable<T> delegate; WrappedCallable(Callable<T> delegate) { this.delegate = delegate; } @Override public T call() throws Exception { return delegate.call(); } } private static final class WrappedRunnable implements Runnable { private final Runnable delegate; WrappedRunnable(Runnable delegate) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 9.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/RandomAmountInputStream.java
import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; import java.util.Random; import org.jspecify.annotations.NullUnmarked; /** Returns a random portion of the requested bytes on each call. */ @NullUnmarked class RandomAmountInputStream extends FilterInputStream { private final Random random; public RandomAmountInputStream(InputStream in, Random random) { super(checkNotNull(in));Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 1.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
new Callable<String>() { @Override public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException, SampleException { MILLISECONDS.sleep(DELAY_MS);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 9.7K bytes - Click Count (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/nullaway/NullawayStatusTask.kt
group = LifecycleBasePlugin.BUILD_GROUP description = "Checks status of NullAway support in this project. Call unqualified to get summary for all projects." } @TaskAction fun action() { val nullawayIncompatibleDeps = nullawayAwareDeps.get().filter { it.hasNullAwayDisabled } val service = statusService.get()Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Aug 20 13:18:23 GMT 2025 - 2.5K bytes - Click Count (0) -
docs/iam/access-management-plugin.md
MinIO now includes support for using an Access Management Plugin. This is to allow object storage access control to be managed externally via a webhook. When configured, MinIO sends request and credential details for every API call to an external HTTP(S) endpoint and expects an allow/deny response. MinIO is thus able to delegate access management to an external system, and users are able to use a custom solution instead of S3 standard IAM policies.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Dec 13 22:28:48 GMT 2022 - 4.4K bytes - Click Count (1) -
internal/grid/debug.go
Mux []*mux.Router Hosts []string cleanupOnce sync.Once cancel context.CancelFunc } // SetupTestGrid creates a new grid for testing purposes. // Select the number of hosts to create. // Call (TestGrid).Cleanup() when done. func SetupTestGrid(n int) (*TestGrid, error) { hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheLoader.java
* CacheBuilder#refreshAfterWrite}, or through a call to {@link LoadingCache#refresh}. * * <p>This implementation synchronously delegates to {@link #load}. It is recommended that it be * overridden with an asynchronous implementation when using {@link * CacheBuilder#refreshAfterWrite}. * * <p><b>Note:</b> <i>all exceptions thrown by this method will be logged and then swallowed</i>. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 9.5K bytes - Click Count (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java
listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED)); Thread.sleep(500); // to make sure queue is processed, cancellation applied // subsequent call will cancel assertThrows( TransferCancelledException.class, () -> listener.transferStarted(event(session, resource, TransferEvent.EventType.STARTED))); } @Test
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sun Dec 01 19:41:22 GMT 2024 - 5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/UnreadableResponseBody.kt
| * Response.cacheResponse | * Response.networkResponse | * Response.priorResponse | * EventSourceListener | * WebSocketListener |(It is safe to call contentType() and contentLength() on these response bodies.) """.trimMargin(), ) override fun timeout() = Timeout.NONE override fun close() { } } fun Response.stripBody(): Response =Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 15:19:53 GMT 2025 - 1.7K bytes - Click Count (0)