- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 101 for consulted (0.06 sec)
-
docs/contribute/concurrency.md
available, we need to hold that thread until either the bytes arrive, the stream is closed, or a timeout elapses. If we get bytes but there's nobody asking for them, we buffer them. We don't consider bytes as delivered for flow control until they're consumed by the application. Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending...
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Dfs.java
if (ki < key.length()) { key = key.substring(0, ki); } /* Subtract the server and share from the pathConsumed so that * it refects the part of the relative path consumed and not * the entire path. */ dr.pathConsumed -= 1 + server.length() + 1 + share.length(); if (referrals != null && (System.currentTimeMillis() + 10000) > referrals.expiration) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 11.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/DfsImpl.java
dr.stripPathConsumed(1 + domain.length() + 1 + root.length()); if ( dr.getPathConsumed() > ( path != null ? path.length() : 0 ) ) { log.error("Consumed more than we provided"); } link = path != null && dr.getPathConsumed() > 0 ? path.substring(0, dr.getPathConsumed()) : "\\"; dr.setLink(link);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:07:29 UTC 2023 - 29.1K bytes - Viewed (0) -
docs/fr/docs/index.md
@app.get("/items/{item_id}") async def read_item(item_id: int, q: Union[str, None] = None): return {"item_id": item_id, "q": q} ``` **Note** Si vous n'êtes pas familier avec cette notion, consultez la section _"Vous êtes pressés ?"_ à propos de <a href="https://fastapi.tiangolo.com/fr/async/#vous-etes-presses" target="_blank">`async` et `await` dans la documentation</a>. </details> ### Lancez
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 22K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
/** * Null once the file has a complete copy of the upstream bytes. Only the [upstreamReader] thread * may access this source. */ var upstream: Source?, /** The number of bytes consumed from [upstream]. Guarded by this. */ var upstreamPos: Long, /** User-supplied additional data persisted with the source data. */ private val metadata: ByteString, /** The maximum size of [buffer]. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
tag = DerHeader.TAG_END_OF_CONTENTS, constructed = false, length = -1L, ) } /** A source that keeps track of how many bytes it's consumed. */ private class CountingSource(source: Source) : ForwardingSource(source) { var bytesRead = 0L override fun read( sink: Buffer, byteCount: Long, ): Long {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TopKSelector.java
} /** * Adds each member of {@code elements} as a candidate for the top {@code k} elements. This * operation takes amortized linear time in the length of {@code elements}. The iterator is * consumed after this operation completes. * * <p>If all input data to this {@code TopKSelector} is in a single {@code Iterator}, prefer * {@link Ordering#leastOf(Iterator, int)}, which provides a simpler API for that use case.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 11.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
service.shutdown(); } assertThat(holder.count).isEqualTo(ITERATION_COUNT); for (int length : completeLengthChecks) { // Verify that at max depth, less than one stack frame per submitted task was consumed assertThat(length - baseStackDepth).isLessThan(DIRECT_EXECUTIONS_PER_THREAD / 2); } } @SuppressWarnings("ObjectToString") // Intended behavior public void testToString() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
docs/fr/docs/alternatives.md
Vous pouvez le combiner avec Gunicorn, pour avoir un serveur multi-processus asynchrone. Pour plus de détails, consultez la section [Déploiement](deployment/index.md){.internal-link target=_blank}. /// ## Benchmarks et vitesse
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 27.6K bytes - Viewed (0) -
docs/es/docs/async.md
* los contenidos que tu programa da al sistema para ser escritos en disco * una operación relacionada con una API remota * una operación de base de datos * el retorno de resultados de una consulta de base de datos * etc.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Aug 19 18:15:21 UTC 2024 - 24.9K bytes - Viewed (0)