- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for ByteArray (0.22 sec)
-
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/symbols/KtFirArrayOfSymbolProvider.kt
val firSymbol = useSiteSession.symbolProvider.getTopLevelCallableSymbols(kotlinPackage, identifier).firstOrNull { /* choose (for byte array) * public fun byteArrayOf(vararg elements: kotlin.Byte): kotlin.ByteArray */ (it as? FirFunctionSymbol<*>)?.fir?.valueParameters?.singleOrNull()?.isVararg == true } as? FirNamedFunctionSymbol ?: return null
Plain Text - Registered: Fri Mar 22 08:18:09 GMT 2024 - Last Modified: Fri Feb 03 14:29:54 GMT 2023 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
private var writerClosed = false /** Lazily initialized on first use. */ private var messageDeflater: MessageDeflater? = null // Masks are only a concern for client writers. private val maskKey: ByteArray? = if (isClient) ByteArray(4) else null private val maskCursor: Buffer.UnsafeCursor? = if (isClient) Buffer.UnsafeCursor() else null /** Send a ping with the supplied [payload]. */ @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseBodyCommon.kt
throw IOException("Content-Length ($contentLength) and stream length ($size) disagree") } return bytes } internal fun ResponseBody.commonClose() = source().closeQuietly() internal fun ByteArray.commonToResponseBody(contentType: MediaType?): ResponseBody { return Buffer() .write(this) .asResponseBody(contentType, size.toLong()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
/** Lazily initialized on first use. */ private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback { @Throws(IOException::class) fun onReadMessage(text: String)
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 (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeSSLSession.kt
override fun getCipherSuite(): String { throw UnsupportedOperationException() } override fun getCreationTime(): Long { throw UnsupportedOperationException() } override fun getId(): ByteArray { throw UnsupportedOperationException() } override fun getLastAccessedTime(): Long { throw UnsupportedOperationException() } override fun getLocalCertificates(): Array<Certificate> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
return buffer.asResponseBody(finalContentType, buffer.size) } /** Returns a new response body that transmits this byte array. */ @JvmStatic @JvmName("create") fun ByteArray.toResponseBody(contentType: MediaType? = null): ResponseBody = commonToResponseBody(contentType) /** Returns a new response body that transmits this byte string. */ @JvmStatic @JvmName("create")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-RequestBodyCommon.kt
*/ @file:Suppress("ktlint:standard:filename") package okhttp3.internal import okhttp3.MediaType import okhttp3.RequestBody import okio.BufferedSink import okio.ByteString fun ByteArray.commonToRequestBody( contentType: MediaType?, offset: Int, byteCount: Int, ): RequestBody { checkOffsetAndCount(size.toLong(), offset.toLong(), byteCount.toLong()) return object : RequestBody() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HuffmanTest.kt
val s = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789" for (i in s.indices) { assertRoundTrip(s.substring(0, i).encodeUtf8()) } val random = Random(123456789L) val buf = ByteArray(4096) random.nextBytes(buf) assertRoundTrip(buf.toByteString()) } private fun assertRoundTrip(data: ByteString) { val encodeBuffer = Buffer() encode(data, encodeBuffer)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Jan 04 05:32:07 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
return source.readByte().toInt() != 0 } fun readBigInteger(): BigInteger { if (bytesLeft == 0L) throw ProtocolException("unexpected length: $bytesLeft at $this") val byteArray = source.readByteArray(bytesLeft) return BigInteger(byteArray) } fun readLong(): Long { if (bytesLeft !in 1..8) throw ProtocolException("unexpected length: $bytesLeft at $this")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
assertThat(callFailed.ioe).isNotNull() assertThat(request.ioe).isNotNull() } private inner class NonCompletingRequestBody : RequestBody() { private val chunk: ByteArray? = ByteArray(1024 * 1024) var ioe: IOException? = null override fun contentType(): MediaType? { return "text/plain".toMediaType() } override fun contentLength(): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0)