- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for numero (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* @param valueCount the number of values per cache entry. Must be positive. * @param maxSize the maximum number of bytes this cache should use to store. */ class DiskLruCache( fileSystem: FileSystem, /** Returns the directory where this cache stores its data. */ val directory: Path, private val appVersion: Int, internal val valueCount: Int,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
} fun run() { try { val count = getTestCount() println("Test count: $count") for (number in 1..count) { runTest(number, count) } updateReports() } finally { client.dispatcher.executorService.shutdown() } } private fun runTest( number: Long, count: Long, ) { val latch = CountDownLatch(1) val startNanos = AtomicLong()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
* limitations under the License. */ package okhttp3.internal.http2.flowcontrol class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/Progress.java
long totalBytesRead = 0L; @Override public long read(Buffer sink, long byteCount) throws IOException { long bytesRead = super.read(sink, byteCount); // read() returns the number of bytes read, or -1 if this source is exhausted. totalBytesRead += bytesRead != -1 ? bytesRead : 0; progressListener.update(totalBytesRead, responseBody.contentLength(), bytesRead == -1);
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 12 03:31:36 GMT 2019 - 3.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
} } private void streamPrimesToSinkAsynchronously(final BufferedSink sink) { Thread thread = new Thread("writer") { @Override public void run() { try { sink.writeUtf8("Numbers\n"); sink.writeUtf8("-------\n"); for (int i = 2; i <= 997; i++) { System.out.println(i); Thread.sleep(10); sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** 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 set /** The total number of bytes permitted to be produced by incoming `WINDOW_UPDATE` frame. */ var writeBytesMaximum: Long = connection.peerSettings.initialWindowSize.toLong() internal set
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
import okhttp3.internal.okHttpName import okhttp3.internal.platform.Platform import okio.IOException class RealConnectionPool( private val taskRunner: TaskRunner, /** * The maximum number of idle connections across all addresses. * Connections needed to satisfy a [ConnectionPool.AddressPolicy] are not considered idle. */ private val maxIdleConnections: Int, keepAliveDuration: Long,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
private val atomicRequestCount = AtomicInteger() /** * The number of HTTP requests received thus far by this server. This may exceed the number of * HTTP connections when connection reuse is in practice. */ val requestCount: Int get() = atomicRequestCount.get() /** The number of bytes of the POST body to keep in memory to the given limit. */ var bodyLimit: Long = Long.MAX_VALUE
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
request.newBuilder() .headers(conditionalRequestHeaders.build()) .build() return CacheStrategy(conditionalRequest, cacheResponse) } /** * Returns the number of milliseconds that the response was fresh for, starting from the served * date. */ private fun computeFreshnessLifetime(): Long { val responseCaching = cacheResponse!!.cacheControl
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* upgrade. * * If the response body is closed before the response body is exhausted, this is invoked at the * time it is closed. In such calls [byteCount] is the number of bytes returned to the * application. This may be smaller than the resource's byte count if were read to completion. * * This method is always invoked after [responseBodyStart]. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0)