- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for Pound (0.12 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
/** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) } /** * Removes recorded events up to (and including) an event is found whose class equals [eventClass] * and returns it. */ fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T { val fullEventSequence = eventSequence.toList() try { while (true) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt
import okio.Buffer import org.junit.jupiter.api.Assumptions.assumeFalse import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource /** * Tests for round-tripping headers through hpack. * * TODO: update hpack-test-case with the output of our encoder. * This test will hide complementary bugs in the encoder and decoder,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
testCase.headersList, hpackReader.getAndResetHeaderList(), ) } } companion object { /** * Reads all stories in the folders provided, asserts if no story found. */ @JvmStatic protected fun createStories(interopTests: Array<String>): List<Any> { if (interopTests.isEmpty()) return listOf<Any>(Story.MISSING) val result = mutableListOf<Any>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.2K bytes - Viewed (0) -
samples/static-server/src/main/java/okhttp3/sample/SampleServer.java
} catch (FileNotFoundException e) { return new MockResponse() .setStatus("HTTP/1.1 404") .addHeader("content-type: text/plain; charset=utf-8") .setBody("NOT FOUND: " + path); } catch (IOException e) { return new MockResponse() .setStatus("HTTP/1.1 500") .addHeader("content-type: text/plain; charset=utf-8") .setBody("SERVER ERROR: " + e); }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Jan 02 02:50:44 GMT 2019 - 4.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
var bitCount = 0L for (i in 0 until bytes.size) { val byteIn = bytes[i] and 0xff bitCount += CODE_BIT_COUNTS[byteIn].toLong() } return ((bitCount + 7) shr 3).toInt() // Round up to an even byte. } fun decode( source: BufferedSource, byteCount: Long, sink: BufferedSink, ) { var node = root var accumulator = 0 var accumulatorBitCount = 0
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.3K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
are currently being read or written. On Windows the file system forbids this so we must be more careful when deleting and renaming files. * Fix: Don't crash on Java 8u252 which introduces an API previously found only on Java 9 and above. See [Jetty's overview][jetty_8_252] of the API change and its consequences. * New: `MultipartReader` is a streaming decoder for [MIME multipart (RFC 2045)][rfc_2045]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Headers.kt
* Set a field with the specified date. If the field is not found, it is added. If the field is * found, the existing values are replaced. */ operator fun set( name: String, value: Date, ) = set(name, value.toHttpDateString()) /** * Set a field with the specified instant. If the field is not found, it is added. If the field * is found, the existing values are replaced. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* from being scheduled. * * Tasks may opt-out of cancellation with `cancelable = false`. Such tasks will recur until they * decide not to by returning -1L. * * Task Queues * ----------- * * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks * within it never execute concurrently. It is an error to use a task in multiple queues. */ abstract class Task( val name: String,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt
headerValue = headerValue, ) } /** * Returns the next index in this at or after [startIndex] that is a character from * [characters]. Returns the input length if none of the requested characters can be found. */ private fun String.indexOfElement( characters: String, startIndex: Int = 0, ): Int { for (i in startIndex until length) { if (this[i] in characters) { return i } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
) assertFailsWith<EOFException> { parts.nextPart() } } /** Confirm that [MultipartBody] and [MultipartReader] can work together. */ @Test fun `multipart round trip`() { val body = MultipartBody.Builder("boundary") .setType(MultipartBody.PARALLEL) .addPart("Quick".toRequestBody("text/plain".toMediaType())) .addFormDataPart("color", "Brown")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.8K bytes - Viewed (0)