- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 466 for consumer (0.05 sec)
-
docs/kms/IAM.md
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
// user-specified -XX:+DisableExplicitGC. // // TODO(user): Consider using // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage() // // TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); }Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
src/bufio/scan.go
} if n > 0 { s.empties = 0 break } loop++ if loop > maxConsecutiveEmptyReads { s.setErr(io.ErrNoProgress) break } } } } // advance consumes n bytes of the buffer. It reports whether the advance was legal. func (s *Scanner) advance(n int) bool { if n < 0 { s.setErr(ErrNegativeAdvance) return false } if n > s.end-s.start {Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed May 21 18:05:26 UTC 2025 - 14.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/general/EditForm.java
@Min(-1) @Max(1000) @ValidateTypeFailure public Integer dayForCleanup; /** * Number of threads to use for crawling operations. * Higher values increase crawling speed but consume more resources. */ @Required @Min(0) @Max(100) @ValidateTypeFailure public Integer crawlingThreadCount; /** * Enable or disable search query logging.Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
// Read a boundary, skipping the remainder of the preceding part as necessary. if (partCount == 0 && source.rangeEquals(0L, dashDashBoundary)) { // This is the first part. Consume "--" followed by the boundary. source.skip(dashDashBoundary.size.toLong()) } else { // This is a subsequent part or a preamble. Skip until "\r\n--" followed by the boundary. while (true) {Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/RegularImmutableMap.java
import com.google.common.collect.ImmutableMapEntry.NonTerminalImmutableMapEntry; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.Serializable; import java.util.IdentityHashMap; import java.util.function.BiConsumer; import org.jspecify.annotations.Nullable; /** * Implementation of {@link ImmutableMap} used for 0 entries and for 2+ entries. AdditionalRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 15.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
* * @param runnable the runnable task * @param result the result to return on successful completion. If you don't need a particular * result, consider using constructions of the form: {@code ListenableFuture<?> f = * ListenableFutureTask.create(runnable, null)} * @since 10.0 */ public static <V extends @Nullable Object> ListenableFutureTask<V> create(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
docs/en/docs/advanced/async-tests.md
The `TestClient` is based on <a href="https://www.python-httpx.org" class="external-link" target="_blank">HTTPX</a>, and luckily, we can use it directly to test the API. ## Example { #example } For a simple example, let's consider a file structure similar to the one described in [Bigger Applications](../tutorial/bigger-applications.md){.internal-link target=_blank} and [Testing](../tutorial/testing.md){.internal-link target=_blank}: ``` . ├── app
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 3.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/xml/XmlEscapersTest.java
} } // Test _all_ allowed characters (including surrogate values). for (char ch = 0x20; ch <= 0xFFFD; ch++) { // There are a small number of cases to consider, so just do it manually. if (ch == '&') { assertEscaping(xmlEscaper, "&", ch); } else if (ch == '<') { assertEscaping(xmlEscaper, "<", ch); } else if (ch == '>') {Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
headers: Headers?, ) : Lockable, Socket { // Internal state is guarded by `this`. No long-running or potentially blocking operations are // performed while the lock is held. /** The bytes consumed and acknowledged by the stream. */ val readBytes: WindowCounter = WindowCounter(id) /** The total number of bytes produced by the application. */ var writeBytesTotal = 0L internal setRegistered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0)