- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for numero (0.16 sec)
-
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 May 03 11:42:14 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 May 03 11:42:14 GMT 2024 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MediaTypeTest.kt
val mediaType = parse("Message/Partial; number=2; total=3; id=\"oc=******@****.***\"") assertEquals("2", mediaType.parameter("number")) assertEquals("3", mediaType.parameter("total")) assertEquals("oc=******@****.***", mediaType.parameter("id")) assertNull(mediaType.parameter("foo")) } @Test fun testRepeatedParameter() { val mediaType = parse("multipart/mixed; number=2; number=3")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* options and then retried without them should the attempt fail. * * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any * number of streams, dynamically configured with `SETTINGS_MAX_CONCURRENT_STREAMS`. A connection
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
private fun Logger.log( task: Task, queue: TaskQueue, message: String, ) { fine("${queue.name} ${String.format("%-22s", message)}: ${task.name}") } /** * Returns a duration in the nearest whole-number units like "999 µs" or " 1 s ". This rounds 0.5 * units away from 0 and 0.499 towards 0. The smallest unit this returns is "µs"; the largest unit * it returns is "s". For values in [-499..499] this returns " 0 µs". *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
} /** A request body that fires events when it completes. */ private inner class RequestBodySink( delegate: Sink, /** The exact number of bytes to be written, or -1L if that is unknown. */ private val contentLength: Long, ) : ForwardingSink(delegate) { private var completed = false private var bytesReceived = 0L
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2)