- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for 1505 (0.15 sec)
-
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
assertThat(buffer.readByteString()).isEqualTo("0D04c27B0302".decodeHex()) } @Test fun `decode raw sequence`() { val buffer = Buffer() .write("300A".decodeHex()) .write("1505".decodeHex()) .write("Smith".encodeUtf8()) .write("01".decodeHex()) .write("01".decodeHex()) .write("FF".decodeHex()) val derReader = DerReader(buffer)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 31.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
} } @Test fun closeReservedThrows() { assertFailsWith<IllegalArgumentException> { clientWriter.writeClose(1005, "Hello".encodeUtf8()) }.also { expected -> assertThat(expected.message).isEqualTo("Code 1005 is reserved and may not be used.") } } @Test fun serverEmptyPing() { serverWriter.writePing(EMPTY) assertData("8900") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// Running at time 149, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(149L)).isEqualTo(1L) assertThat(pool.connectionCount()).isEqualTo(1) assertThat(c1.socket().isClosed).isFalse() // Running at time 150, the pool evicts. assertThat(pool.closeConnections(150L)).isEqualTo(0) assertThat(pool.connectionCount()).isEqualTo(0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
callback.assertPing("Hello".encodeUtf8()) } @Test fun emptyCloseCallsCallback() { data.write("8800".decodeHex()) // Empty close clientReader.processNextFrame() callback.assertClosing(1005, "") } @Test fun closeLengthOfOneThrows() { data.write("880100".decodeHex()) // Close with invalid 1-byte payload assertFailsWith<ProtocolException> { clientReader.processNextFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.processNextFrame() client.listener.assertClosing(1005, "") client.webSocket!!.finishReader() assertThat(client.webSocket!!.close(1000, "Bye!")).isTrue() server.processNextFrame() server.listener.assertClosing(1000, "Bye!") server.webSocket!!.finishReader() client.listener.assertClosed(1005, "") } @Test fun clientCloseClosesConnection() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/idn/rfc3454.B.2.txt
1F82; 1F02 03B9; Case map 1F83; 1F03 03B9; Case map 1F84; 1F04 03B9; Case map 1F85; 1F05 03B9; Case map 1F86; 1F06 03B9; Case map 1F87; 1F07 03B9; Case map 1F88; 1F00 03B9; Case map 1F89; 1F01 03B9; Case map 1F8A; 1F02 03B9; Case map 1F8B; 1F03 03B9; Case map 1F8C; 1F04 03B9; Case map 1F8D; 1F05 03B9; Case map 1F8E; 1F06 03B9; Case map 1F8F; 1F07 03B9; Case map
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 38.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val CLOSE_CLIENT_GOING_AWAY = 1001 /** Used when an empty close frame was received (i.e., without a status code). */ internal const val CLOSE_NO_STATUS_CODE = 1005 fun toggleMask( cursor: Buffer.UnsafeCursor, key: ByteArray, ) { var keyIndex = 0 val keyLength = key.size do { val buffer = cursor.data var i = cursor.start
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000 /** * The smallest message that will be compressed. We use 1024 because smaller messages already * fit comfortably within a single ethernet packet (1500 bytes) even with framing overhead. * * For tests this must be big enough to realize real compression on test messages like * 'aaaaaaaaaa...'. Our tests check if compression was applied just by looking at the size if
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
} /** * We delay sending the last byte of the request body 1500 ms. The 1000 ms read timeout should * only elapse 1000 ms after the request body is sent. */ @Test fun headersReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() { enableProtocol(Protocol.HTTP_2) server.enqueue( MockResponse.Builder() .headersDelay(1500, TimeUnit.MILLISECONDS) .build(), ) val request =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
val delays = mutableListOf(50.µs, 150.µs, -1L) redQueue.schedule("task", 100.µs) { log += "run@${taskFaker.nanoTime}" return@schedule delays.removeAt(0) } taskFaker.advanceUntil(0.µs) assertThat(log).containsExactly() taskFaker.advanceUntil(100.µs) assertThat(log).containsExactly("run@100000") taskFaker.advanceUntil(150.µs)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0)