- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for ByteArray (0.17 sec)
-
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
): MatchResult? { val candidate = find(input, index) ?: return null if (candidate.range.first != index) return null // Didn't match where it should have. return candidate } @JvmField val EMPTY_BYTE_ARRAY: ByteArray = ByteArray(0) /** Byte order marks. */ internal val UNICODE_BOMS = Options.of( // UTF-8. "efbbbf".decodeHex(), // UTF-16BE. "feff".decodeHex(), // UTF-16LE. "fffe".decodeHex(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
/** 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 val end = cursor.end if (buffer != null) {
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/test/java/okhttp3/internal/cache2/FileOperatorTest.kt
} assertFailsWith<IndexOutOfBoundsException> { operator.write(0, buffer, 4L) } } private fun randomByteString(byteCount: Int): ByteString { val bytes = ByteArray(byteCount) Random(0).nextBytes(bytes) return ByteString.of(*bytes) } private fun snapshot(): ByteString { randomAccessFile!!.getChannel().force(false) val source = file!!.source().buffer()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(1)), 1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
@JvmField var errorCode: ErrorCode? = null @JvmField var windowSizeIncrement: Long = 0 @JvmField var headerBlock: List<Header>? = null @JvmField var data: ByteArray? = null @JvmField var settings: Settings? = null @JvmField var ack = false @JvmField var payload1 = 0 @JvmField var payload2 = 0 override fun settings(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
assertThat(actual).isEqualTo(expected) } companion object { private fun binaryData(length: Int): ByteString { val junk = ByteArray(length) Random(0).nextBytes(junk) return junk.toByteString() } }
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/main/kotlin/okhttp3/internal/platform/Platform.kt
/** * Returns the concatenation of 8-bit, length prefixed protocol names. * http://tools.ietf.org/html/draft-agl-tls-nextprotoneg-04#page-4 */ fun concatLengthPrefixed(protocols: List<Protocol>): ByteArray { val result = Buffer() for (protocol in alpnProtocolNames(protocols)) { result.writeByte(protocol.length) result.writeUtf8(protocol) } return result.readByteArray()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
* @param debugData only valid for HTTP/2; opaque debug data to send. */ @Throws(IOException::class) fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteArray, ) { this.withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) { "errorCode.httpCode == -1" } frameHeader( streamId = 0,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
}.also { expected -> assertThat(expected.message!!).contains("closed") } } private fun binaryData(length: Int): ByteString { val junk = ByteArray(length) random.nextBytes(junk) return junk.toByteString() }
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)