- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 229 for buffer (0.38 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt
internal fun idnToAscii(host: String): String? { val bufferA = Buffer().writeUtf8(host) val bufferB = Buffer() // 1. Map, from bufferA to bufferB. while (!bufferA.exhausted()) { val codePoint = bufferA.readUtf8CodePoint() if (!IDNA_MAPPING_TABLE.map(codePoint, bufferB)) return null } // 2. Normalize, from bufferB to bufferA. val normalized = normalizeNfc(bufferB.readUtf8()) bufferA.writeUtf8(normalized)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
@Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.sendBufferSize = SOCKET_BUFFER_SIZE socket.receiveBufferSize = SOCKET_BUFFER_SIZE return socket } }, ) .sslSocketFactory( handshakeCertificates.sslSocketFactory(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
byteCount: Int, inFinished: Boolean, ) { val buffer = Buffer() source.require(byteCount.toLong()) // Eagerly read the frame before firing client thread. source.read(buffer, byteCount.toLong()) pushQueue.execute("$connectionName[$streamId] onData") { ignoreIoExceptions { val cancel = pushObserver.onData(streamId, buffer, byteCount, inFinished)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
@JvmName("create") fun String.toResponseBody(contentType: MediaType? = null): ResponseBody { val (charset, finalContentType) = contentType.chooseCharset() val buffer = Buffer().writeString(this, charset) return buffer.asResponseBody(finalContentType, buffer.size) } /** Returns a new response body that transmits this byte array. */ @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/test/java/okhttp3/InterceptorTest.kt
} } } private fun gzip(data: String): Buffer { val result = Buffer() val sink = GzipSink(result).buffer() sink.writeUtf8(data) sink.close() return result } private fun addInterceptor( network: Boolean, interceptor: Interceptor, ) { val builder = client.newBuilder() if (network) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/IdnStringprep.kt
* exists for it. */ operator fun invoke(input: String): String? = invoke(Buffer().writeUtf8(input)) internal operator fun invoke(input: BufferedSource): String? { // 1. Map. val mapResult = Buffer() while (!input.exhausted()) { val codePoint = input.readUtf8CodePoint() when (val mappedCodePoint = mapping[codePoint]) {
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt
*/ fun toDer( writer: DerWriter, value: T, ) fun toDer(value: T): ByteString { val buffer = Buffer() val writer = DerWriter(buffer) toDer(writer, value) return buffer.readByteString() } /** * Returns an adapter that expects this value wrapped by another value. Typically this occurs
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/IdnaMappingTableTest.kt
private fun String.map(): String { val buffer = Buffer() for (codePoint in codePoints()) { require(table.map(codePoint, buffer)) } return buffer.readUtf8() } private fun String.mapExpectingErrors(): String { val buffer = Buffer() var errorCount = 0 for (codePoint in codePoints()) { if (!table.map(codePoint, buffer)) errorCount++ }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} fun body(body: Buffer) = body(body.toMockResponseBody()) fun body(body: MockResponseBody) = apply { setHeader("Content-Length", body.contentLength) this.body = body } /** Sets the response body to the UTF-8 encoded bytes of [body]. */ fun body(body: String): Builder = body(Buffer().writeUtf8(body))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
* See the License for the specific language governing permissions and * limitations under the License. * */ package mockwebserver3.internal import okio.Buffer import okio.Sink /** * A sink that sleeps [periodDelayNanos] every [bytesPerPeriod] bytes. Unlike [okio.Throttler], * this permits any interval to be used. */ internal class ThrottledSink(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0)