- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 311 for Celery (0.05 seconds)
-
internal/bucket/bandwidth/reader.go
tokens = need + hdr } else { // part of header can be accommodated r.opts.HeaderSize -= b - 1 need = 1 // to ensure we read at least one byte for every Read tokens = b } } else { // all tokens go towards payload need = int(math.Min(float64(b), float64(need))) tokens = need } // reduce tokens requested according to availabilityCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/FilesSimplifyPathTest.java
// Inputs are /b/c/<every possible 10-character string of characters "a./"> // Expected outputs are from realpath -s. doExtensiveTest("testdata/simplifypathwithabsoluteprefixtests.txt"); } public void testExtensiveNoPrefix() throws IOException { /* * Inputs are <every possible 10-character string of characters "a./"> *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 11K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
import okhttp3.internal.okHttpName /** * Speculatively connects to each IP address of a target address, returning as soon as one of them * connects successfully. This kicks off new attempts every 250 ms until a connect succeeds. */ internal class FastFallbackExchangeFinder( override val routePlanner: RoutePlanner, private val taskRunner: TaskRunner, ) : ExchangeFinder {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 5.8K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/ExtractDslMetaDataTask.groovy
parse(f, repository) counter++ } //updating/modifying the metadata and making sure every type reference across the metadata is fully qualified //so, the superClassName, interfaces and types needed by declared properties and declared methods will have fully qualified name
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Jan 08 12:45:57 GMT 2024 - 4.4K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/EquivalenceTester.java
delegate.test(); } return this; } private void testItems() { for (T item : items) { /* * TODO(cpovirk): consider no longer running these equivalent() tests on every Equivalence, * since the Equivalence base type now implements this logic itself */ assertTrue(item + " must be inequivalent to null", !equivalence.equivalent(item, null));
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 4.1K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/EquivalenceTester.java
delegate.test(); } return this; } private void testItems() { for (T item : items) { /* * TODO(cpovirk): consider no longer running these equivalent() tests on every Equivalence, * since the Equivalence base type now implements this logic itself */ assertTrue(item + " must be inequivalent to null", !equivalence.equivalent(item, null));
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 4.1K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
public fun socketHandler(socketHandler: SocketHandler): Builder = apply { this.socketHandler = socketHandler } /** * Sets the response body to [body], chunked every [maxChunkSize] bytes. */ public fun chunkedBody( body: Buffer, maxChunkSize: Int = Int.MAX_VALUE, ): Builder = apply { removeHeader("Content-Length")Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 17.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Range.java
* <li>{@code (3..6]} does not enclose {@code [3..6]} * <li>{@code [4..5]} does not enclose {@code (3..6)} (even though it contains every value * contained by the latter range) * <li>{@code [3..6]} does not enclose {@code (1..1]} (even though it contains every value * contained by the latter range) * </ul> * * <p>Note that if {@code a.encloses(b)}, then {@code b.contains(v)} implies {@code
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 28K bytes - Click Count (0) -
docs/works_with_okhttp.md
* ⬜️ [Okio](https://github.com/square/okio/): A modern I/O API for Java. * [OkLog](https://github.com/simonpercic/OkLog): Response logging interceptor for OkHttp. Logs a URL link with URL-encoded response for every OkHttp call. * [Okurl](https://github.com/yschimke/okurl/wiki) A curl-like client for social networks and other APIs. * [PersistentCookieJar](https://github.com/franmontiel/PersistentCookieJar): A persistent `CookieJar`.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 26 07:59:38 GMT 2025 - 3.8K bytes - Click Count (0) -
guava/src/com/google/common/hash/PrimitiveSink.java
* for cross-language compatibility. For other use cases, prefer {@link #putUnencodedChars}, which * is faster, produces the same output across Java releases, and processes every {@code char} in * the input, even if some are invalid. */ @CanIgnoreReturnValue PrimitiveSink putString(CharSequence charSequence, Charset charset);Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 3.9K bytes - Click Count (0)